Struct PrivateStreamClient 

pub struct PrivateStreamClient { /* private fields */ }

Client for the private account socket (/v1/ws/private).

Credentials are mandatory — the endpoint rejects an unauthenticated upgrade — so they are taken by value rather than as an Option.

Implementations

impl PrivateStreamClient

pub fn new(auth: UsAuth) -> Self

Connect to the default private endpoint.

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

Point the client at a non-default host or path. See MarketStreamClient::with_base_url.

pub fn base_url(&self) -> &str

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

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

pub async fn run<F, Fut>( &self, subscriptions: Vec<PrivateSubscription>, 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 PrivateStreamClient

fn clone(&self) -> PrivateStreamClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.