Crate atomr_streams_io 

atomr-streams-io

Real-world I/O Source/Sink adapters for atomr-streams, behind feature flags so the core streams crate stays dependency-light:

• http — HttpPollSource: periodic / conditional GET polling.
• ws — WsSource: WebSocket frame source with reconnect.

Token-bucket rate limiting lives upstream in atomr_streams::rate (token_bucket, token_bucket_keyed, respect_retry_after) so backpressure and limiting are uniform across all sources.

Modules

http_poll

HTTP polling Source adapters.

ws

WebSocket frame Source with automatic reconnect.