atrg-stream 0.1.0

Jetstream consumer wiring for at-rust-go
Documentation

Jetstream consumer wiring for at-rust-go.

Provides a bounded, backpressure-aware Jetstream consumer that spawns as a background task and delivers events to a user-supplied handler.

This crate is deliberately independent of atrg-core to avoid cyclic dependencies. It defines its own [StreamConfig] that atrg-core maps its JetstreamConfig into before calling [spawn_consumer].