Components

Collect

Buffered accumulator with a boolean flush gate. Each tick pulls one {{type:Bool}} from the gate stream and one {{type:t}} from the value stream; while the gate is true the value is appended to an internal list; on the FIRST tick where the gate goes `fals

Filter

Drops messages that fail a {{type:Bool}} predicate. Pairs a value stream with a boolean stream that ticks alongside it.

Animate Face (face vid2vid)

Drives a static reference face with the expressions and pose of an incoming video stream using face-vid2vid. The reference face stays the same identity; the driver frames supply the motion.

Unpack Record

Splits a record-typed stream into one output stream per field, preserving declared field order. Inverse of {{component:pack_record}}.

Input Image File

Image-file directory streamer. The worker enumerates files under the {{param:image}} directory slot, loads each through OpenCV imread, optionally resizes to {{param:width}} x {{param:height}} via INTER_LINEAR, and emits the {{type:Image}} at {{param:fps}

Pack Union

Combines multiple input streams into one union-typed output. Each emitted value carries its original variant tag. Inverse of {{component:unpack_union}}.

Visualize Expression

Variadic image renderer driven by a Python expression. {{param:expression}} is evaluated via asteval with the variadic inputs bound to x0, x1, ... and helpers from NumPy / OpenCV / scikit-image / Matplotlib in scope. When {{param:icons}} is true the

Input Text File

Text file streamer. The worker enumerates files under the {{param:text}} directory slot, reads each one into memory, and emits the bytes as a single {{type:String}} message per file; {{param:repeat}} loops the directory and {{param:fps}} paces the loop.

Lift Unroll

Splits a list-typed stream into a size stream plus an element stream. The size stream ticks once per input list; the element stream ticks once per element in order. Inverse of {{component:lift_reroll}}.

Transcribe Audio (Moonshine)

Moonshine ASR transcriber (UsefulSensors). Loads {{param:model_name}} (AutoModelForSpeechSeq2Seq + AutoProcessor) on {{param:device}} with FP16 on CUDA / FP32 on CPU, resamples each {{type:AudioFrame}} to 16 kHz, caps max_length at `attention_mask.su

Unpack Union

Splits a union-typed stream into one output per variant. Exactly one output ticks per input message — the variant that matched.

Detect Objects (Triton)

Triton-served object detector. The worker preprocesses each {{type:Image}} (letterbox, colour cast, normalise, channel/batch reshape) and sends it through the Triton checkpoint registered as {{param:model}}; raw detections are decoded, NMS-suppressed, opti

Detect Object Containment

Per-rectangle polygon containment gate. Each {{type:Rectangle}} input is reduced to a single anchor (foot or centre, picked by {{param:anchor_mode}}) and tested against the polygon registered in {{param:roi}}; the worker emits {{type:Bool}} true

Sketch

Undeployable placeholder for sketching pipeline intent before a real component exists. Carries free-form notes in a {{param:readme}} parameter and intentionally fails deploy so unfinished pipelines cannot ship.

Detect Zone Transition

Per-tracked-id zone transition classifier. Each input is a {{type:[(UInt64, Bool)]}} list of (id, in_zone) pairs for the current tick; the worker updates per-id rolling history of length {{param:history_size}} and emits {{type:[UInt64]}} carrying a trans

Repeat

Emits the second input value n times on every paired tick, where n comes from the first input.

Limit Message Rate

Throttles {{type:t}} to a target rate by dropping messages. Useful when the downstream consumer is slower than upstream and back-pressure isn't acceptable.

Delay by One

Delays a stream by one tick. Emits a configured initial value first, then on every input tick emits the value seen on the previous tick.