Enum Consumer

pub enum Consumer {
    Python(Option<Arc<PyObject>>),
    Rust(Sender<Message>),
}

Defines how WebSocket messages are consumed.

Variants

Python(Option<Arc<PyObject>>)

Python-based message handler.

Rust(Sender<Message>)

Rust-based message handler using a channel sender.

Implementations

impl Consumer

pub fn rust_consumer() -> (Self, Receiver<Message>)

Creates a Rust-based consumer with a channel for receiving messages.

Returns a tuple containing the consumer and a receiver for messages.

Trait Implementations

impl Clone for Consumer

fn clone(&self) -> Consumer

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Consumer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.