Flow
Represents active collection on a source Flow which buffers item emissions, completion, and/or errors as events for consuming.
Functions
Assert that the next event received was the flow completing. If no events have been received, this function will suspend for up to timeout.
Assert that the next event received was an error terminating the flow. If no events have been received, this function will suspend for up to timeout.
Assert that an event was received and return it. If no events have been received, this function will suspend for up to timeout.
Cancel collecting events from the source Flow. Any events which have already been received will be returned.
Cancel collecting events from the source Flow and ignore any events which have already been received. Calling this function will exit the test block.
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.
Properties
Duration in milliseconds that awaitItem, awaitComplete, awaitError, and awaitEvent will wait before throwing a timeout exception.
Extensions
Duration that awaitItem, awaitComplete, awaitError, and awaitEvent will wait before throwing a timeout exception.