Struct PolymarketMarketConnectionPool 

pub struct PolymarketMarketConnectionPool { /* private fields */ }

A pool of market-channel WebSocket connections that shards asset subscriptions.

Implementations

impl PolymarketMarketConnectionPool

pub fn new( base_url: Option<String>, subscribe_new_markets: bool, transport_backend: TransportBackend, max_subscriptions: usize, ) -> Self

Creates a new market connection pool (unconnected).

A max_subscriptions of 0 is invalid and clamps to WS_DEFAULT_SUBSCRIPTIONS with a warning.

pub fn new_with_proxy( base_url: Option<String>, subscribe_new_markets: bool, transport_backend: TransportBackend, max_subscriptions: usize, proxy_url: Option<ProxyUrl>, ) -> Self

Creates a new market connection pool with an optional validated proxy URL.

pub fn handle(&self) -> PolymarketMarketPoolHandle

Returns a cloneable routing handle for use in spawned subscription tasks.

pub async fn connect(&self) -> Result<()>

Opens the primary shard and prepares the merged message stream.

Errors

Returns an error if the primary connection cannot be established.

pub async fn subscribe_new_markets_feed(&self) -> Result<()>

Sends the new-market discovery subscribe on the primary shard.

Errors

Returns an error if no primary shard is available.

pub fn take_message_receiver( &self, ) -> Option<UnboundedReceiver<PolymarketWsMessage>>

Takes the merged message receiver, leaving None in its place.

pub async fn disconnect(&self) -> Result<()>

Disconnects every shard and clears routing state.

Errors

Returns an error after attempting every shard when a task or connection does not stop.

pub fn connection_count(&self) -> usize

Returns the number of open shard connections.

pub fn subscription_count(&self) -> usize

Returns the number of unique assets assigned across all shards.

Trait Implementations

impl Debug for PolymarketMarketConnectionPool

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

Formats the value using the given formatter.