ktor-server-core/io.ktor.server.request/ApplicationReceivePipeline

ApplicationReceivePipeline

open class ApplicationReceivePipeline(val developmentMode: Boolean = false) : Pipeline<Any, PipelineCall>

A pipeline for processing incoming content. When executed, this pipeline starts with an instance of ByteReadChannel.

Constructors

ApplicationReceivePipeline

constructor(developmentMode: Boolean = false)

Types

object Phases

Pipeline phases.

Properties

val attributes: Attributes

developmentMode

open override val developmentMode: Boolean = false

val isEmpty: Boolean

val items: List<PipelinePhase>

Functions

fun addPhase(phase: PipelinePhase)

afterIntercepted

open fun afterIntercepted()

suspend fun execute(context: PipelineCall, subject: Any): Any

insertPhaseAfter

fun insertPhaseAfter(reference: PipelinePhase, phase: PipelinePhase)

insertPhaseBefore

fun insertPhaseBefore(reference: PipelinePhase, phase: PipelinePhase)

installDefaultTransformations

fun ApplicationReceivePipeline.installDefaultTransformations()

Default receive transformation

fun intercept(phase: PipelinePhase, block: suspend PipelineContext<Any, PipelineCall>.(Any) -> Unit)

interceptorsForPhase

fun interceptorsForPhase(phase: PipelinePhase): List<suspend PipelineContext<Any, PipelineCall>.(Any) -> Unit>

fun merge(from: Pipeline<Any, PipelineCall>)

fun mergePhases(from: Pipeline<Any, PipelineCall>)

fun resetFrom(from: Pipeline<Any, PipelineCall>)

open override fun toString(): String