create

fun <T : Response> create(httpClient: HttpClient, requestBuilder: RequestBuilder, serializer: KSerializer<T>, listener: EventListener<T>, reconnectTimeout: Duration = DEFAULT_RECONNECT_TIMEOUT): SSEStream<T>

Creates and starts a new SSE stream.

Return

A new SSEStream instance

Parameters

T

The type of response objects expected from the stream

httpClient

The HTTP client to use for the connection

requestBuilder

The request builder containing URL and parameters

serializer

The serializer for deserializing event data

listener

The event listener for callbacks

reconnectTimeout

Optional custom reconnect timeout