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) {
    throw FayeError.network('Not connected');
  }

  try {
    final response = await _sendRequest(messages);

    // Handle batch response
    if (response is List) {
      for (final message in response) {
        emitMessage(message);
      }
    } else {
      emitMessage(response);
    }

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