Pipe.subscribe

Subscribe to the data sent by this publisher. Only one subscriber can be assigned to a pipe at once.

For high-level API, use then.

class Pipe(Return, Args...)
override
void
subscribe
in (this.next is null, "Pipe already has a subscriber. Cannot subscribe (then).")

Parameters

subscriber Subscriber!Output

Subscriber to register.

Meta