log-core/com.log.vastgui.core.pipeline/Pipeline

Pipeline

open class Pipeline<TSubject : Any, TContext : Any>(phases: PipelinePhase)(source)

Since

1.3.4

Inheritors

Constructors

constructor(vararg phases: PipelinePhase)

Properties

interceptorsQuantity

private var interceptorsQuantity: Int

val isEmpty: Boolean

val items: List<PipelinePhase>

private val phasesRaw: MutableList<Any>

Contains a list of PipelinePhase and PhaseContent.

Functions

fun addPhase(phase: PipelinePhase)

Add phase to the end of phasesRaw.

afterIntercepted

open fun afterIntercepted()

cacheInterceptors

private fun cacheInterceptors(): List<PipelineInterceptor<TSubject, TContext>>

private fun createContext(context: TContext, subject: TSubject): PipelineContext<TSubject, TContext>

internal fun execute(context: TContext, subject: TSubject): TSubject

Executes this pipeline in the given context and with the given subject.

private fun findPhase(phase: PipelinePhase): PhaseContent<TSubject, TContext>?

Find phase matching phase in phasesRaw. If PhaseContent exists and its phase matches phase, return this object. If PipelinePhase and phase match, convert PipelinePhase to PhaseContent and return. Otherwise return empty.

private fun findPhaseIndex(phase: PipelinePhase): Int

Find index matching phase in phasesRaw. Returns the index if PhaseContent exists and its phase matches phase .If there is a matching PipelinePhase, return the index of the PipelinePhase. Otherwise return -1.

private fun hasPhase(phase: PipelinePhase): Boolean

Find phase matching phase in phasesRaw. Returns true if PhaseContent exists and its phase matches phase , Returns true if there is a matching PipelinePhase. Otherwise return false .

insertPhaseAfter

fun insertPhaseAfter(reference: PipelinePhase, phase: PipelinePhase)

Insert phase as PhaseContent after the reference phase. If there are other phases inserted after reference, then phase will be inserted after them.

insertPhaseBefore

fun insertPhaseBefore(reference: PipelinePhase, phase: PipelinePhase)

Inserts phase as PhaseContent before the reference phase.

insertRelativePhase

private fun insertRelativePhase(fromPhaseOrContent: Any, fromPhase: PipelinePhase): Boolean

fun intercept(phase: PipelinePhase, block: PipelineInterceptor<TSubject, TContext>)

Adds block to the phase of this pipeline.

interceptorsForPhase

fun interceptorsForPhase(phase: PipelinePhase): List<PipelineInterceptor<TSubject, TContext>>

fun merge(from: Pipeline<TSubject, TContext>)

mergeInterceptors

private fun mergeInterceptors(from: Pipeline<TSubject, TContext>)

fun mergePhases(from: Pipeline<TSubject, TContext>)