StreamChannelCompleter() { _channel = new StreamChannel<T>(_streamCompleter.stream, _sinkCompleter.sink); }