PipelineContext

abstract class PipelineContext<TSubject : Any, TContext : Any>(val context: TContext) : CoroutineScope

Represents running execution of a pipeline

context

: object representing context in which pipeline executes

Constructors

abstract fun finish()

Finishes current pipeline execution

abstract suspend fun proceed(): TSubject

Continues execution of the pipeline with the same subject

abstract suspend fun proceedWith(subject: TSubject): TSubject

Continues execution of the pipeline with the given subject

Subject of this pipeline execution that goes along the pipeline

open override fun CoroutineScope.decode(source: ByteReadChannel): ByteReadChannel

Launch coroutine to decode source bytes.

open override fun CoroutineScope.encode(source: ByteReadChannel): ByteReadChannel

Launch coroutine to encode source bytes.