SAService ArchitectDocumentation

/

DocumentationStream types

Reference

Stream types

One article for every stream operator implemented by the designer and ServiceLib.

Sources and destinations

InputAdmits data from an endpoint into a service pipeline.Endpoint → TSinkSends a pipeline value to an external endpoint.T → Endpoint

Transformations

MapTransforms every input value into exactly one output value.T → RFilterKeeps values that satisfy a generated predicate.T → T?FlatMapExpands one input into zero or more output values using business logic.T → 0..N RFlatMapIterableUnwraps an iterable stream without a generated function.Iterable<R> → RProcessRuns stateful or side-effecting processing with a dedicated error output.T → 0..N R + E

Keys and state

KeyByExtracts a comparable key and creates a keyed stream.T → KeyValue<K,V>JoinCombines two keyed streams using a stateful matching policy.KV<K,A> + KV<K,B> → RMultiJoinCorrelates three or more keyed streams into one result.N × KV<K,T> → R

Routing and topology

MergeCombines multiple streams of the same message type.N × T → TSplitBroadcasts each value to multiple downstream consumers.T → N × TCaseChooses one of several When branches using generated business logic.T → branch indexWhenRepresents one typed branch owned by a Case operator.Case<T> → RErrorConsumes the typed error side output of Input, Process or Sink.EDelayDefers downstream delivery by a fixed or per-element duration.T → T laterCycleLinkMarks an explicit feedback path to an earlier graph node.T ↺