CachingAction

abstract class CachingAction<in T : Any, out R : Any>(outputType: KType) : Action<T, R>

An action that caches results on-demand and recalculates them on source push

Constructors

CachingAction

common

fun CachingAction(outputType: KType)

Functions

execute

common

open suspend override fun execute(dataSet: DataSet<T>, meta: Meta, scope: CoroutineScope?): DataSet<R>

Transform the data in the node, producing a new node. By default it is assumed that all calculations are lazy so not actual computation is started at this moment.

Properties

outputType

common

val outputType: KType