Struct OptionChainSink 

pub struct OptionChainSink(/* private fields */);

A feed’s destination for complete chain snapshots. Cheap to clone. Only the latest accepted rows and error are retained; updates never queue.

Implementations

impl OptionChainSink

pub fn push(&self, rows: Vec<OptionQuote>) -> Result<(), FeedError>

Replace all rows, including clearing them with an empty snapshot, and wake the host. Reject the whole snapshot with FeedError::InvalidData for an invalid field, expiry outside the query or more than 100,000 rows. The error names the contract and field, is exposed by OptionChain::error, and leaves the previous rows untouched. A successful push clears the last error. Inactive sinks ignore pushes.

pub fn report_error(&self, error: FeedError)

Report a feed failure and wake the host, retaining the last accepted rows. A historical request ends on a reported error; a live request can recover on a later push.

pub fn is_active(&self) -> bool

Whether a consumer remains and, for a historical request, still awaits an answer. Stop producing when false, including after the last handle is dropped.

Trait Implementations

impl Clone for OptionChainSink

fn clone(&self) -> OptionChainSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.