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
1.1.2