send method

@override void send(dynamic message)

Send a message through the transport

Implementation

@override
void send(dynamic message) {
  final jsonString = jsonEncode(message);
  final eventData = 'event: message\ndata: $jsonString\n\n';

  // Snapshot to avoid mutation during async dispatch.
  final sessions = List<MapEntry<String, HttpResponse>>.from(
    _sessionClients.entries,
  );
  for (final entry in sessions) {
    final sessionId = entry.key;
    final client = entry.value;
    final compressionType =
        _sessionCompression[sessionId] ?? CompressionType.none;
    _enqueueSend(sessionId, client, eventData, compressionType);
  }
}