Turbine

Add an item to the underlying Channel without blocking.

Returns the underlying Channel. The Channel will have a buffer size of UNLIMITED.

Assert that the next event received was the flow completing. This function will suspend if no events have been received.

Assert that the next event received was an error terminating the flow. This function will suspend if no events have been received.

Assert that an event was received and return it. This function will suspend if no events have been received.

Assert that the next event received was an item and return it. This function will suspend if no events have been received.

Cancel this ReceiveTurbine.

Cancel this ReceiveTurbine and return any events which have already been received.

Cancel this ReceiveTurbine and ignore any events which have already been received.

Closes the underlying Channel. After all items have been consumed, this Turbine will yield Event.Complete if cause is null, and Event.Error otherwise.

Assert that all events that have occurred so far on this ReceiveTurbine have been consumed.

Returns the most recent item that has already been received. If a complete event has been received with no item being received previously, this function will throw an AssertionError. If an error event has been received, this function will throw the underlying exception.

Assert that there are no unconsumed events which have already been received.

Assert that count item events were received and ignore them. This function will suspend if no events have been received.

Assert that the next event received is Event.Complete. This function will not suspend. On JVM and Android, it will attempt to throw if invoked in a suspending context.

Assert that the next event received is Event.Error, and return the error. This function will not suspend. On JVM and Android, it will attempt to throw if invoked in a suspending context.

Assert that the next event received was non-null and return it. This function will not suspend. On JVM and Android, it will attempt to throw if invoked in a suspending context.

Assert that the next event received was an item and return it. This function will not suspend. On JVM and Android, it will attempt to throw if invoked in a suspending context.