send method

  1. @override
void send(
  1. AbstractMessage message
)
override

Implementation

@override
void send(AbstractMessage message) {
  if (message is Goodbye) {
    _goodbyeSent = true;
  }
  if (!_handshakeCompleter.isCompleted) {
    if (_outboundBuffer!.isEmpty) {
      _handshakeCompleter.future.then((aVoid) {
        _send0(_outboundBuffer!);
        _outboundBuffer = null;
      });
    }
    var serialalizedMessage = _serializer.serialize(message);
    _outboundBuffer!.addAll(SocketHelper.buildMessageHeader(
        SocketHelper.messageWamp,
        serialalizedMessage.length,
        isUpgradedProtocol));
    _outboundBuffer!.addAll(serialalizedMessage);
  } else {
    var serialalizedMessage = _serializer.serialize(message);
    _send0(SocketHelper.buildMessageHeader(SocketHelper.messageWamp,
        serialalizedMessage.length, isUpgradedProtocol));
    _send0(serialalizedMessage);
  }
}