create static method

Future<SseHeartbeatClientTransport> create({
  1. required String serverUrl,
  2. Map<String, String>? headers,
  3. HeartbeatConfig? heartbeatConfig,
})

Create SSE transport with heartbeat monitoring

Implementation

static Future<SseHeartbeatClientTransport> create({
  required String serverUrl,
  Map<String, String>? headers,
  HeartbeatConfig? heartbeatConfig,
}) async {
  final transport = SseHeartbeatClientTransport._internal(
    serverUrl: serverUrl,
    headers: headers,
    heartbeatConfig: heartbeatConfig,
  );

  try {
    await transport._establishConnection();
    return transport;
  } catch (e) {
    transport.close();
    throw McpError('Failed to establish heartbeat SSE connection: $e');
  }
}