moqtap-client 0.3.0

MoQT client library — QUIC transport, endpoint state machine, subscribe/fetch/namespace flows
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

//! Connection observer trait for receiving structured events.

use crate::draft12::event::ClientEvent;

/// Trait for receiving events from a MoQT connection.
///
/// Implementations must be `Send + Sync` because the connection may emit
/// events from async tasks. The `on_event` method takes `&self` (not
/// `&mut self`) -- implementations that need mutation should use interior
/// mutability (e.g., `Mutex`, `mpsc::Sender`).
///
/// The callback is synchronous to keep the hot path simple. Implementations
/// that need async processing should send to an internal channel.
pub trait ConnectionObserver: Send + Sync {
    /// Called when a connection event occurs.
    fn on_event(&self, event: &ClientEvent);

    /// Called with an owned event. Default implementation forwards to
    /// `on_event(&event)`. Override to consume the event without cloning --
    /// used by the cross-draft dispatch adapter to move the event directly
    /// into its `AnyClientEvent` variant.
    fn on_event_owned(&self, event: ClientEvent) {
        self.on_event(&event);
    }
}

/// A no-op observer that discards all events.
pub struct NoOpObserver;

impl ConnectionObserver for NoOpObserver {
    fn on_event(&self, _event: &ClientEvent) {}
}