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

SubstitutionEngine

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

Handles the logic of how data is created, when it's substituted instead of the previous value of a shared resource, and how it's substituted back

Inheritors

BlockingSubstitutionEngine

NonBlockingSubstitutionEngine

Constructors

SubstitutionEngine

constructor(dataFlowComponents: DataFlowComponents<DataT>)

Functions

withDataSubstitution

abstract 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.