Function
send-stream
Produce a stream of records with backpressure.
The provider stops reading while its bounded queues are full. The returned future resolves only after the input ends and every record the provider accepted has a delivery outcome. A record becomes accepted when the provider has reserved its bounded capacity and taken it from the input stream. If the workload, binding or provider stops first, the future reports an error because accepted records may have an unknown outcome.
A provider may impose a documented per-record size limit when its component runtime cannot determine a streamed item's size before lowering it into host memory.
send-stream: async func(topic: string, records: stream<produce-record>) -> future<result<_, error>>;