Struct RelayConnection 

pub struct RelayConnection { /* private fields */ }

Handle to a relay WebSocket connection running in its own thread.

Each connection runs in a dedicated OS thread with non-blocking I/O. The thread can be signaled to shut down via an atomic flag.

Implementations

impl RelayConnection

pub fn spawn( relay_url: String, producer: Producer<PoolMessage>, outbound: Consumer<String>, shutdown: Arc<AtomicBool>, ) -> Self

Spawn a new thread that connects to a relay with bidirectional messaging.

The thread reads inbound events into the MPSC ring buffer and sends outbound messages from the broadcast consumer to the WebSocket.

pub fn is_finished(&self) -> bool

Returns true if the connection thread has exited.

pub fn request_shutdown(&self)

Signal the connection thread to shut down gracefully.

The thread will send a WebSocket Close frame and exit within one poll cycle (~1ms). Does not block.

pub fn relay_url(&self) -> &str

Get the relay URL

Trait Implementations

impl Drop for RelayConnection

fn drop(&mut self)

Executes the destructor for this type.