Struct MarketStreamClient 

pub struct MarketStreamClient { /* private fields */ }

Client for the market-data socket (/v1/ws/markets).

Implementations

impl MarketStreamClient

pub fn new(auth: Option<UsAuth>) -> Self

Connect to the default markets endpoint.

Auth is optional here so the same client can be used before credentials are configured, but note that the live endpoint has been observed to reject unauthenticated upgrades with 401.

pub fn with_base_url(base_url: impl Into<String>, auth: Option<UsAuth>) -> Self

Point the client at a non-default host or path — a staging venue, or a local server in tests.

A URL with no path gets the endpoint’s default path appended; a URL that already has one is used as given.

pub fn base_url(&self) -> &str

pub async fn connect( &self, subscriptions: Vec<MarketSubscription>, ) -> Result<MarketStream, PolymarketUsError>

pub async fn connect_with_config( &self, subscriptions: Vec<MarketSubscription>, config: StreamConnectConfig, ) -> Result<MarketStream, PolymarketUsError>

pub async fn run<F, Fut>( &self, subscriptions: Vec<MarketSubscription>, config: StreamConnectConfig, on_message: F, ) -> Result<(), PolymarketUsError>

where F: FnMut(StreamMessage) -> Fut, Fut: Future<Output = ()>,

Connect and drive a callback until the stream closes.

Trait Implementations

impl Clone for MarketStreamClient

fn clone(&self) -> MarketStreamClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.