Stream<T> take(int count)

Provides at most the first count data events of this stream.

Forwards all events of this stream to the returned stream until count data events have been forwarded or this stream ends, then ends the returned stream with a done event.

If this stream produces fewer than count data events before it's done, so will the returned stream.

Starts listening to this stream when the returned stream is listened to and stops listening when the first count data events have been received.

This means that if this is a single-subscription (non-broadcast) streams it cannot be reused after the returned stream has been listened to.

If this is a broadcast stream, the returned stream is a broadcast stream. In that case, the events are only counted from the time the returned stream is listened to.

Source

Stream<T> take(int count) {
  return new _TakeStream<T>(this, count);
}