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.

Returns whether the worker should continue (True) or stop (False).

Push values from a driver to a fold worker via a Channel. 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 wroker.