FutureOr closeStream(Stream<T> stream) { if (_subscriptions.containsKey(stream)) { return _subscriptions.remove(stream)!.cancel(); } }