Module transformers 

Built-in transformer implementations. Transformers module.

This module provides a collection of stream transformers for processing and transforming data as it flows through pipelines.

Modules

backpressure

Backpressure transformer for managing stream flow control. Backpressure transformer module.

batch

Batch transformer for grouping items into batches. Batch transformer module.

broadcast

Broadcast transformer for sending items to multiple outputs. Broadcast transformer module.

buffer

Buffer transformer for buffering stream items. Buffer transformer module.

chunk

Chunk transformer for splitting streams into chunks. Chunk transformer module.

circuit_breaker

Circuit breaker transformer module.

concat

Concat transformer for concatenating streams. Concat transformer module.

debounce

Debounce transformer module.

dedupe

Dedupe transformer for removing duplicate items. Dedupe transformer module.

delay

Delay transformer module.

distinct

Distinct transformer for keeping only distinct items. Distinct transformer module.

filter

Filter transformer for filtering stream items.

flat_map

Flat map transformer for flattening mapped collections. Flat map transformer module.

flatten

Flatten transformer for flattening collections.

group_by

Group by transformer for grouping items by key.

interleave

Interleave transformer for interleaving multiple streams. Interleave transformer module.

join

Join transformer module.

limit

Limit transformer for limiting the number of items. Limit transformer module.

map

Map transformer for transforming items. Map transformer module.

merge

Merge transformer for merging multiple streams. Merge transformer module.

message_dedupe

Message dedupe transformer for removing duplicate messages. Message deduplication transformer module.

moving_average

Moving average transformer for calculating moving averages. Moving average stateful transformer.

ordered_merge

Ordered merge transformer module.

partition

Partition transformer for partitioning streams. Partition transformer module.

rate_limit

Rate limit transformer module.

reduce

Reduce transformer for reducing streams to a single value. Reduce transformer module.

retry

Retry transformer module.

round_robin

Round robin transformer for distributing items in round-robin fashion. Round-robin transformer module.

router

Router transformer for routing items to different outputs. Router transformer module.

running_sum

Running sum transformer for calculating running sums. Running sum stateful transformer.

sample

Sample transformer module.

skip

Skip transformer for skipping items from the beginning. Skip transformer module.

sort

Sort transformer for sorting stream items. Sort transformer module.

split

Split transformer for splitting streams based on a predicate. Split transformer module.

split_at

Split at transformer for splitting streams at a specific index. Split at transformer module.

take

Take transformer for taking a specified number of items. Take transformer module.

timeout

Timeout transformer module.

window

Window transformer for creating sliding windows. Window transformer module.

zip

Zip transformer for zipping multiple streams. Zip transformer module.