Struct HttpLongPollClient 

pub struct HttpLongPollClient<H, O> { /* private fields */ }

An HTTP long-poll client that connects to a Subduction server.

After connecting, spawn the returned ConnectResult::poll_task and ConnectResult::send_task futures to drive the connection.

Type Parameters

• H: The HTTP client implementation
• O: The timeout strategy

Implementations

impl<H, O> HttpLongPollClient<H, O>

pub fn new( base_url: &str, http: H, timeout: O, default_time_limit: Duration, ) -> Self

Create a new HTTP long-poll client.

• base_url: The server’s base URL, e.g., http://localhost:8080.
• http: The HTTP client implementation.
• timeout: The timeout strategy.
• default_time_limit: Default timeout for call operations.

impl<H, O> HttpLongPollClient<H, O>

pub fn connect<'a, K: FutureForm, Sig: Signer<K>>( &'a self, signer: &'a Sig, expected_peer_id: PeerId, now: TimestampSeconds, ) -> K::Future<'a, Result<ConnectResult<K, O>, ClientError>>

where Self: Connect<K, Sig, Timeout = O>, HttpLongPollConnection<O>: Connection<K>,

Connect to the server with a known peer ID.

The FutureForm variant K is inferred from the HTTP client H: Sendable for native clients, Local for browser fetch().

Errors

Returns ClientError if the handshake or connection setup fails.

pub fn connect_discover<'a, K: FutureForm, Sig: Signer<K>>( &'a self, signer: &'a Sig, service_name: &str, now: TimestampSeconds, ) -> K::Future<'a, Result<ConnectResult<K, O>, ClientError>>

where Self: Connect<K, Sig, Timeout = O>, HttpLongPollConnection<O>: Connection<K>,

Connect to the server using service discovery.

The FutureForm variant K is inferred from the HTTP client H: Sendable for native clients, Local for browser fetch().

Errors

Returns ClientError if the handshake or connection setup fails.

Trait Implementations

impl<H: Clone, O: Clone> Clone for HttpLongPollClient<H, O>

fn clone(&self) -> HttpLongPollClient<H, O>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Sig: Signer<Local>, H: HttpClient<Local> + 'static, O: Timeout<Local> + Clone + 'static> Connect<Local, Sig> for HttpLongPollClient<H, O>

type Timeout = O

The timeout strategy for the resulting connection.

fn connect_with_audience<'a>( &'a self, signer: &'a Sig, audience: Audience, now: TimestampSeconds, ) -> LocalBoxFuture<'a, Result<ConnectResult<Local, O>, ClientError>>

where HttpLongPollConnection<O>: Connection<Local>,

Connect with a specific Audience (known peer ID or service discovery).

impl<Sig, H, O> Connect<Sendable, Sig> for HttpLongPollClient<H, O>

where H: Send + Sync + HttpClient<Sendable> + 'static, O: Send + Sync + Timeout<Sendable> + Clone + 'static, Sig: Sync + Signer<Sendable>, H::Error: Send,

type Timeout = O

The timeout strategy for the resulting connection.

fn connect_with_audience<'a>( &'a self, signer: &'a Sig, audience: Audience, now: TimestampSeconds, ) -> BoxFuture<'a, Result<ConnectResult<Sendable, O>, ClientError>>

where HttpLongPollConnection<O>: Connection<Sendable>,

Connect with a specific Audience (known peer ID or service discovery).

impl<H: Debug, O: Debug> Debug for HttpLongPollClient<H, O>

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

Formats the value using the given formatter.