Struct FullSub 

pub struct FullSub { /* private fields */ }

Live full-tx subscription. Call FullSub::next in a loop.

Implementations

impl FullSub

pub async fn next(&mut self) -> Result<Option<Frame>>

Awaits the next transaction frame. Frame::Unknown message types are skipped transparently for forward compatibility, and Frame::Heartbeat frames update FullSub::heartbeat instead of being returned. Only Frame::Tx is ever handed back here. Returns Ok(None) at a clean end of stream.

pub fn heartbeat(&self) -> Option<(u64, u64)>

The most recent heartbeat observed on this stream: (server_ts_ms, highest_seq). highest_seq == NO_SEQ_ASSIGNED means the server has not assigned this subscriber a transaction yet. None means no heartbeat has arrived at all yet (a busy stream can go a long time without one — the server resets its heartbeat timer on every real send).

Unlike SigFirstSub::gaps, the full-tx wire carries no per-frame sequence number, so this SDK cannot compute a numeric gap count for this tier — highest_seq is the raw signal a caller can compare against its own received-frame count if it wants that.

pub async fn update_filter( &self, filter: &Filter, fields: &[&str], ) -> Result<Ack>

Updates the active filter/enrichment fields live (opens a fresh control stream) and returns the server’s parsed ack. The tier cannot change after the first control message.