stop method

Future stop()

Implementation

Future stop() {
  assert(_subscriptions.isNotEmpty);
  _log.info('Stopping forwarding');
  for (var s in _subscriptions) {
    s.cancel();
  }
  _subscriptions.clear();
  _closedController.add(null);
  return Future.wait([_closedController.close(), _out.close()]);
}