Struct QuoteStream 

pub struct QuoteStream { /* private fields */ }

A handle to an active quote stream.

When dropped, automatically sends StopStream to the server.

Implementations

impl QuoteStream

pub fn new( stream_id: u32, receiver: Receiver<SwapQuotes>, connection: Arc<Connection>, ) -> Self

Create a new quote stream handle (unmanaged, for backwards compatibility).

pub fn new_managed( stream_id: u32, receiver: Receiver<SwapQuotes>, connection: Arc<Connection>, manager: Option<Arc<StreamManager>>, effective_stream_id: Arc<AtomicU32>, stopped_flag: Arc<AtomicBool>, slot_released: Arc<AtomicBool>, ) -> Self

Create a new managed quote stream handle.

pub fn stream_id(&self) -> u32

Get the original stream ID assigned at creation.

pub fn effective_stream_id(&self) -> u32

Get the current effective stream ID (may differ after reconnection).

pub async fn recv(&mut self) -> Option<SwapQuotes>

Receive the next quote update.

Returns None when the stream ends.

pub async fn stop(&mut self) -> Result<(), TitanClientError>

Explicitly stop the stream.

This is called automatically on drop, but can be called manually if you want to handle the result.

Trait Implementations

impl Drop for QuoteStream

fn drop(&mut self)

Executes the destructor for this type.