StreamRouter<T> constructor

StreamRouter<T>(
  1. Stream<T> incoming
)

Create a new StreamRouter that listens to the incoming stream.

Implementation

StreamRouter(Stream<T> incoming) : _incoming = incoming {
  _subscription = _incoming.listen(_handle, onDone: close);
}