send package:streamly

This function is used by the producer threads to queue output for the consumer thread to consume. Returns whether the queue has more space.

Low level API to add an event on the channel's output queue. Atomically adds the event to the queue and rings the doorbell if needed to wakeup the consumer thread.

Add a ChildStop event with exception to the channel's output queue.

Add a ChildStop event to the channel's output queue. When rate control is enabled, it pushes the worker latency stats to the channel.

Add a ChildYield event to the channel's output queue. This is a wrapper over sendEvent, it does a few more things:

• performs a buffer limit check, returns False if exceeded

When rate control is enabled and WorkerInfo is supplied::

• increments the worker yield count
• periodically pushes the worker latency stats to the channel
• performs a rate limit check, returns False if exceeded

Push values from a driver to a fold worker via a Channel. Blocks if no space is available in the buffer. Before pushing a value to the Channel it polls for events received from the fold worker. If a stop event is received then it returns True otherwise false. Propagates exceptions received from the fold worker.

Like sendToWorker but only sends, does not receive any events from the fold.

Noop as of now.

Noop as of now.