Subscribe a sink to a stream, returning a nested job. (Shorthand for .connect(...) on the active job.)
An event source or signal
A callback that will receive the events
Optional
Optional - a throttle() to control backpressure
A job that can be aborted to end the subscription, and which will end naturally (with a void return or error) if the stream ends itself.
Subscribe a sink to a stream, returning a nested job. (Shorthand for .connect(...) on the active job.)