ReceiveTurbine

Returns the underlying ReceiveChannel.

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.

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.