StreamRouter<T> constructor

StreamRouter<T>(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);
}