Pipeline

class Pipeline<I, O>(source)

A type-safe processing pipeline represented as a directed graph.

Pipelines consist of nodes (processing steps) connected by edges (data flow). They support sequential, conditional, and parallel execution patterns.

Parameters

I

Pipeline input type

O

Pipeline output type

Properties

Link copied to clipboard

Name of the entry node that receives pipeline input.

Link copied to clipboard

Name of the exit node that produces pipeline output.

Link copied to clipboard

Name identifier for this pipeline.

Functions

Link copied to clipboard
fun execute(input: I): O

Execute the pipeline with the given input.

Link copied to clipboard
fun getNode(name: String): Node<*, *>?

Get a node by name.

Link copied to clipboard
fun hasNode(name: String): Boolean

Check if a node exists.

Link copied to clipboard

Get all node names.

Link copied to clipboard
fun <R> then(other: Pipeline<O, R>): Pipeline<I, R>

Compose this pipeline with another, creating a sequential chain.