emitMessage method

  1. @protected
void emitMessage(
  1. Map<String, dynamic> message
)

Emit a message

Implementation

@protected
void emitMessage(Map<String, dynamic> message) {
  _logger.info('BaseTransport: Emitting message: $message');
  _logger.info('BaseTransport: Message type: ${message.runtimeType}');
  _messageController.add(message);
  _statistics['messagesReceived']++;
  _statistics['bytesReceived'] += jsonEncode(message).length;
  updateLastActivity();
}