ObservableContent

class ObservableContent(val delegate: OutgoingContent, callContext: CoroutineContext, listener: ProgressListener) : OutgoingContent.ReadChannelContent(source)

Constructors

constructor(delegate: OutgoingContent, callContext: CoroutineContext, listener: ProgressListener)

open override val contentLength: Long?

open override val contentType: ContentType?

val delegate: OutgoingContent

open override val headers: Headers

open override val status: HttpStatusCode?

open override fun <T : Any> getProperty(key: AttributeKey<T>): T?

open override fun readFrom(): ByteReadChannel

open fun readFrom(range: LongRange): ByteReadChannel

open override fun <T : Any> setProperty(key: AttributeKey<T>, value: T?)

open fun trailers(): Headers?

fun OutgoingContent.wrapHeaders(block: (Headers) -> Headers): OutgoingContent

Generates a new OutgoingContent of the same abstract type but with OutgoingContent.headers transformed by the specified block.