sendMessage method

Implementation

@override
Future<void> sendMessage(
  Message message, {
  bool attemptReconnect = true,
}) async {
  if (_connectionStatusValue.isDisconnected || _transport == null) {
    throw StateError('Client not connected');
  }

  final data = _messageCodec.encode(message);

  // ignore: prefer_asserts_with_message assert function
  assert(() {
    if (data == null) {
      throw StateError(
        '[WebSocketClient] cannot send a message that cannot be encoded.'
        ' Have you added the plugin to the client?'
        '\nMessage: $message',
      );
    }
    return true;
  }());

  if (data == null) {
    return;
  }

  try {
    await _transport!.send(data);

    if (await _handshakeCompleted) {
      _updateConnectionStatus(ConnectionStatus.connected);
    }
  } catch (e) {
    _handleTransportError(
      e,
      attemptReconnect: attemptReconnect,
    );
    rethrow;
  }
}