incoming property

@override Stream<List<int>> get incoming

Stream of incoming data, one event per message sent by the peer.

Implementation

@override
Stream<List<int>> get incoming async* {
  await for (final event in _webSocket.events) {
    switch (event) {
      case TextDataReceived(:final text):
        yield utf8.encode(text);
      case BinaryDataReceived(:final data):
        yield data;
      case CloseReceived():
        return;
    }
  }
}