atproto-jetstream 0.6.0

AT Protocol Jetstream event consumer library with WebSocket streaming and compression support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

//! AT Protocol Jetstream event consumer library.
//!
//! Provides async stream consumption and event handling for AT Protocol Jetstream
//! with support for WebSocket connections, event dispatching, and handler registration.
//!
//! ## Key Features
//!
//! - **Async Stream Consumer**: High-performance WebSocket-based event consumption
//! - **Event Handler Registration**: Flexible event handler system with multiple handlers
//! - **Compression Support**: Optional Zstandard compression with dictionary support
//! - **Graceful Shutdown**: Cancellation token support for clean shutdown
//! - **Error Handling**: Comprehensive error types following project conventions

#![warn(missing_docs)]

pub mod consumer;

pub use consumer::{
    Consumer, ConsumerError, ConsumerTaskConfig, EventHandler, JetstreamEvent,
    JetstreamEventCommit, JetstreamEventDelete, LoggingHandler,
};

// Re-export CancellationToken for convenience
pub use tokio_util::sync::CancellationToken;