WebSocketClient constructor

WebSocketClient({
  1. required String url,
  2. required CRDTDocument document,
  3. required PeerId author,
  4. Compressor? compressor,
})

Constructor

Implementation

WebSocketClient({
  required this.url,
  required this.document,
  required this.author,
  Compressor? compressor,
})  : _messageController = StreamController<Message>.broadcast(),
      _connectionStatusController =
          StreamController<ConnectionStatus>.broadcast(),
      _connectionStatusValue = ConnectionStatus.disconnected {
  _syncManager = SyncManager(document: document, client: this);

  _messageCodec = CompressedCodec<Message>(
    JsonMessageCodec<Message>(
      toJson: (message) => message.toJson(),
      fromJson: Message.fromJson,
    ),
    compressor: compressor ?? NoCompression.instance,
  );

  messages.listen(_handleMessage);
}