attachReader method

void attachReader(
  1. StreamSubscription<Object?> reader
)

The reader to pause. Paused at once if the backlog is already over.

Implementation

void attachReader(StreamSubscription<Object?> reader) {
  _reader = reader;
  if (_over) reader.pause();
}