shared-compiler/org.jetbrains.kotlinx.jupyter.streams/BlockingSubstitutionEngine

BlockingSubstitutionEngine

class BlockingSubstitutionEngine<DataT>(dataFlowComponents: DataFlowComponents<DataT>) : SubstitutionEngine<DataT>

Implements the logic of substitution for StreamSubstitutionType.BLOCKING

Constructors

constructor(dataFlowComponents: DataFlowComponents<DataT>)

Functions

withDataSubstitution

open override fun <T> withDataSubstitution(dataFactory: DataFactory<DataT>, body: () -> T): T

Substitutes the data provided by dataFactory instead of a shared resource (which is done by substitutor), executes body in this context and calls finalizer afterwards. Note that finalizer is called even in the case of exceptional completion of body.