run method

StreamSubscription<List<int>> run()

Implementation

StreamSubscription<List<int>> run() {
  // _inputSubscription = _input.listen();
  // return _inputSubscription;
  // return _inputSubscription.asFuture();
  return _input.listen();
}