ktor-client-core/io.ktor.client.plugins.sse/DefaultClientSSESession

DefaultClientSSESession

class DefaultClientSSESession(content: SSEClientContent, input: ByteReadChannel, val coroutineContext: CoroutineContext) : ClientSSESession

Constructors

DefaultClientSSESession

constructor(content: SSEClientContent, input: ByteReadChannel, coroutineContext: CoroutineContext)

Properties

coroutineContext

open override val coroutineContext: CoroutineContext

open override val incoming: Flow<ServerSentEvent>

An incoming server-sent events flow.

Functions

mapEngineExceptions

fun CoroutineScope.mapEngineExceptions(input: ByteReadChannel, request: HttpRequestData): ByteReadChannel

Returns ByteReadChannel with ByteChannel.close handler that returns SocketTimeoutException instead of SocketTimeoutException.

fun CoroutineScope.mapEngineExceptions(output: ByteWriteChannel, request: HttpRequestData): ByteWriteChannel

Returns ByteWriteChannel with ByteChannel.close handler that returns SocketTimeoutException instead of SocketTimeoutException.