initialTimeout
If the first element has not passed through this operators before the provided timeout, the stream is failed with a TimeoutException
.
Signature
Source.initialTimeout
Source.initialTimeout
Flow.initialTimeout
Flow.initialTimeout
Description
If the first element has not passed through this operators before the provided timeout, the stream is failed with a TimeoutException
.
Reactive Streams semantics
emits when upstream emits an element
backpressures when downstream backpressures
completes when upstream completes or fails if timeout elapses before first element arrives
cancels when downstream cancels