Stream of incoming data, one event per message sent by the peer.
@override Stream<List<int>> get incoming { return _channel.stream.map(frameToBytes); }