FramedWebSocket constructor

FramedWebSocket(
  1. StreamChannel<Uint8List> _channel, {
  2. int maxMessageSize = defaultMaxMessageSize,
})

Implementation

FramedWebSocket(this._channel, {int maxMessageSize = defaultMaxMessageSize})
  : _assembler = WebSocketMessageAssembler(maxMessageSize: maxMessageSize) {
  _frames = _channel.stream
      .transform(WebSocketFrameDecoder(maxFrameSize: maxMessageSize))
      .listen(
        _onFrame,
        onError: _onError,
        onDone: _onDone,
        cancelOnError: true,
      );
}