Control backpressure for listening streams. This interface is the API internal to the implementation of backpressure(). Unless you're implementing a backpressurable stream yourself, see the Throttle interface instead.
Is the main connection open? (i.e. is the creating job not closed yet?)
Is the connection ready to receive data?
Register a callback to produce more data when the inlet is resumed (The callback is unregistered if the supplied job ends.)
Control backpressure for listening streams. This interface is the API internal to the implementation of backpressure(). Unless you're implementing a backpressurable stream yourself, see the Throttle interface instead.