mokksy/me.kpavlov.mokksy.response/StreamResponseDefinition

StreamResponseDefinition

open class StreamResponseDefinition<P, T>(val chunkFlow: <Error class: unknown class><T>? = null, val chunks: List<T>? = null, val delayBetweenChunks: <Error class: unknown class> = Duration.ZERO, contentType: <Error class: unknown class> = ContentType.Text.EventStream.withCharset(Charsets.UTF_8), httpStatus: <Error class: unknown class> = HttpStatusCode.OK, headers: <Error class: unknown class>.() -> Unit? = null, headerList: List<<Error class: unknown class><String, String>> = emptyList<Pair<String, String>>(), delay: <Error class: unknown class>) : AbstractResponseDefinition<T>

Represents a definition for streaming responses, supporting chunked data and flow-based content streaming. This class extends the base AbstractResponseDefinition to provide additional functionality specific to chunked or streamed responses. It can handle flow-based content delivery, manage chunk-wise delays, and supports various output formats such as OutputStream, Writer, or ServerSSESession.

Parameters

The type of the request body.

The type of the response data being streamed.

Inheritors

SseStreamResponseDefinition

Constructors

StreamResponseDefinition

constructor(chunkFlow: <Error class: unknown class><T>? = null, chunks: List<T>? = null, delayBetweenChunks: <Error class: unknown class> = Duration.ZERO, contentType: <Error class: unknown class> = ContentType.Text.EventStream.withCharset(Charsets.UTF_8), httpStatus: <Error class: unknown class> = HttpStatusCode.OK, headers: <Error class: unknown class>.() -> Unit? = null, headerList: List<<Error class: unknown class><String, String>> = emptyList<Pair<String, String>>(), delay: <Error class: unknown class>)

Initializes a streaming response definition with the specified flow, chunk list, content type, HTTP status code, and headers.