Pipes the content of stream into the channel
stream
@override Future<void> pipe(Stream<T> stream) async { final ss = stream.listen((event) { send(event); }); await ss.asFuture(); }