Struct TwapStream 

pub struct TwapStream { /* private fields */ }

One sequenced wallet-scoped TWAP progress stream for one market. The first event is the snapshot; later events are twap_update, heartbeat, or recovery snapshots on the same stream identity. Any identity or sequence mismatch fails closed so the caller reconnects and recovers from a fresh snapshot.

Implementations

impl TwapStream

pub fn market_id(&self) -> &str

pub fn wallet_address(&self) -> &str

pub async fn next_event( &mut self, ) -> Result<Option<PlatformTwapEvent>, SdkError>

Receive and validate the next event. Ok(None) means the peer closed cleanly. Callers should reconnect after any error or close.

pub async fn close(&mut self) -> Result<(), SdkError>

Trait Implementations

impl Debug for TwapStream

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

Formats the value using the given formatter.