agntcy-slim-session 0.3.0

SLIM session internal implementation.
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

// Copyright AGNTCY Contributors (https://github.com/agntcy)
// SPDX-License-Identifier: Apache-2.0

mod common;
pub mod completion_handle;
pub mod context;
pub mod controller_sender;
pub mod errors;

pub mod mls_state;
mod moderator_task;
pub mod notification;
pub mod producer_buffer;
pub mod receiver_buffer;
pub mod session;
mod session_builder;
pub mod session_config;
pub mod session_controller;
mod session_layer;
mod session_moderator;
mod session_participant;
pub mod session_receiver;
pub mod session_sender;
pub mod session_settings;
pub mod subscription_manager;
pub mod timer;
pub mod timer_factory;
pub mod traits;

// Runtime-agnostic helpers (await seam for the MLS sync/async split) shared by
// the modules above so the same source compiles for native tokio and the wasm32
// browser runtime. Imported by path: `use crate::runtime::maybe_await;`.
mod runtime;

// Test utilities (only available during tests)
#[cfg(test)]
pub mod test_utils;

// Traits
pub use traits::MessageHandler;

// Re-export the unified builder for convenience
pub use session_builder::{ForController, ForModerator, ForParticipant, SessionBuilder};

// Session Errors
pub use errors::SessionError;

// Session Config
pub use session_config::SessionConfig;

// Session Layer
pub use session_layer::{Direction, SessionLayer};

// Common Session Types - internal use
pub use common::{MessageDirection, SESSION_RANGE, SessionMessage, SlimChannelSender};

// Session output types
pub use common::{OutboundMessage, SessionOutput};

// Public exports for external crates (like Python bindings)
pub use common::{AppChannelReceiver, SESSION_UNSPECIFIED};

// Re-export specific items that need to be publicly accessible
pub use completion_handle::CompletionHandle;
pub use notification::Notification;
pub use subscription_manager::{AutoAckManager, SubscriptionOps};