onRead()
Stream<String> onRead() => _readChannel.receiveBroadcastStream().map((buffer) => buffer.toString());