sendBatch method

  1. @override
Future<void> sendBatch(
  1. List<Map<String, dynamic>> messages
)
override

Send multiple messages to the server

Implementation

@override
Future<void> sendBatch(List<Map<String, dynamic>> messages) async {
  if (!connected || _channel == null) {
    throw FayeError.network('Not connected');
  }

  try {
    final jsonMessages = jsonEncode(messages);
    _channel!.sink.add(jsonMessages);

    for (final message in messages) {
      recordMessageSent(message);
    }
  } catch (e) {
    emitError(FayeError.network('Failed to send batch: $e'));
    rethrow;
  }
}