subscribe abstract method

Subscription<T> subscribe(
  1. StreamSubscriber<T> subscriber
)

Attaches a StreamSubscriber, which will be invoked when new items are available from the stream.

observer The subscriber to attach.

Returns a subscription that can be disposed to terminate the stream and stop calling methods on the StreamSubscriber.

Implementation

Subscription<T> subscribe(StreamSubscriber<T> subscriber);