pipe method

  1. @override
Future<void> pipe(
  1. Stream<T> stream
)
override

Pipes the content of stream into the channel

Implementation

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