skainet-pipeline/sk.ainet.pipeline/pipeline

pipeline

fun <I, O> pipeline(name: String, block: PipelineBuilder<I, O>.() -> Unit): Pipeline<I, O>(source)

Creates a new pipeline using the DSL.

Example:

val myPipeline = pipeline<String, Int>("parser") {
    node<String, List<String>>("tokenize") { input ->
        input.split(" ")
    }
    node<List<String>, Int>("count") { tokens ->
        tokens.size
    }
}

Return

Configured pipeline

Parameters

name

Pipeline identifier

block

DSL configuration block