stream-tungstenite 0.6.1

A streaming implementation of the Tungstenite WebSocket protocol
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
25
26
27
28

//! Message handling module.
//!
//! This module provides message dispatching and routing functionality.
//!
//! # Components
//!
//! - **`MessageDispatcher`**: Handles sending and receiving messages
//!
//! # Example
//!
//! ```rust,ignore
//! use stream_tungstenite::message::{MessageDispatcher, DispatcherConfig};
//!
//! // Create dispatcher
//! let config = DispatcherConfig::new()
//!     .with_receive_timeout(Duration::from_secs(30));
//! let dispatcher = Arc::new(MessageDispatcher::new(config));
//!
//! // Subscribe to messages
//! let mut messages = dispatcher.subscribe();
//!
//! // Send a message
//! dispatcher.send(tungstenite::Message::Text("Hello, World!".into())).await?;
//! ```

mod dispatcher;

pub use dispatcher::{DispatcherConfig, MessageDispatcher, ProcessorErrorPolicy, SharedMessage};