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.

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

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

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

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

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

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