The number of elements in this stream.

Waits for all elements of this stream. When this stream ends,the returned future is completed with the number of elements.

If this stream emits an error,the returned future is completed with that error,and processing stops.

This operation listens to this stream, and a non-broadcast stream cannotbe reused after finding its length.

Implementation

Future<int> get length {  _Future<int> future = _Future<int>();  int count = 0;  this.listen(    (_) {      count++;    },    onError: future._completeError,    onDone: () {      future._complete(count);    },    cancelOnError: true,  );  return future;}