This documentation regards version 2.10.4+4-4ab9d551-SNAPSHOT, however the current version is 2.10.4.
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
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