backpressureTimeout

If the time between the emission of an element and the following downstream demand exceeds the provided timeout, the stream is failed with a TimeoutException.

Time aware operators

Signature

Source.backpressureTimeoutSource.backpressureTimeout Flow.backpressureTimeoutFlow.backpressureTimeout

Description

If the time between the emission of an element and the following downstream demand exceeds the provided timeout, the stream is failed with a TimeoutException. The timeout is checked periodically, so the resolution of the check is one period (equals to timeout value).

Reactive Streams semantics