TaskResultBuilder

class TaskResultBuilder<T : Any>(workspace: Workspace, taskName: Name, taskMeta: Meta, dataDrop: DataSetBuilder<T>) : DataSetBuilder<T>

Functions

emit
Link copied to clipboard
common
open suspend override fun emit(name: Name, dataSet: DataSet<T>)
open suspend override fun emit(name: Name, data: Data<T>?)
put
Link copied to clipboard
common
open infix suspend override fun String.put(block: suspend DataSetBuilder<T>.() -> Unit)
open infix suspend override fun String.put(dataSet: DataSet<T>)
open infix suspend override fun String.put(data: Data<T>)
remove
Link copied to clipboard
common
open suspend override fun remove(name: Name)

Properties

dataType
Link copied to clipboard
common
open override val dataType: KType
taskMeta
Link copied to clipboard
common
val taskMeta: Meta
taskName
Link copied to clipboard
common
val taskName: Name
workspace
Link copied to clipboard
common
val workspace: Workspace

Extensions

allData
Link copied to clipboard
common
val TaskResultBuilder<*>.allData: DataSelector<*>
data
Link copied to clipboard
inline fun <T : Any> TaskResultBuilder<*>.data(namePattern: Name? = null): DataSelector<T>
from
Link copied to clipboard
common
suspend fun <T : Any> TaskResultBuilder<*>.from(selector: DataSelector<T>): DataSet<T>

Select data using given selector

fromTask
Link copied to clipboard
inline suspend fun <T : Any> TaskResultBuilder<*>.fromTask(task: Name, taskMeta: Meta = Meta.EMPTY): DataSet<T>
pipeFrom
Link copied to clipboard
common
inline suspend fun <T : Any, R : Any> TaskResultBuilder<R>.pipeFrom(selector: DataSelector<T>, crossinline action: suspend (T, name: Name, meta: Meta) -> R)

Perform a lazy mapping task using given selector and action. The meta of resulting TODO move selector to receiver with multi-receivers