AlexSteelax 

Easy code generation in runtime

Easily build a dataflow pipeline using building blocks

Testcontainers provider-like extension

Source generator for Steelax.Pufflow dataflow pipelines. Generates IFlowable implementation from [Flow]-annotated classes.

High-performance primitives (lock-free queues, event tasks, fan-in signaling) used by Steelax.Pufflow dataflow pipelines.

A library for building dataflow pipelines based on Poll and Push models and their combinations.

Operators (Buffer, Chunk, Timeout, Warm, ...) for Steelax.Pufflow dataflow pipelines.

Kafka integration (Consumer source with watermark progress tracking) for Steelax.Pufflow dataflow pipelines.

Test SDK (sources and sinks over System.Threading.Channels) for writing tests against Steelax.Pufflow dataflow pipelines.

Kafka test SDK (in-memory Kafka test producer/consumer) for writing tests against Steelax.Pufflow Kafka pipelines.