pub struct WebSocketClientEpochBuilder<S: State = Empty> { /* private fields */ }Expand description
Use builder syntax to set the inputs and finish with connect().
Implementations§
Source§impl<S: State> WebSocketClientEpochBuilder<S>
impl<S: State> WebSocketClientEpochBuilder<S>
Sourcepub async fn connect(self) -> Result<WebSocketClient, TransportError>where
S: IsComplete,
pub async fn connect(self) -> Result<WebSocketClient, TransportError>where
S: IsComplete,
Finishes building and performs the requested action.
Sourcepub fn config(
self,
value: WebSocketConfig,
) -> WebSocketClientEpochBuilder<SetConfig<S>>where
S::Config: IsUnset,
pub fn config(
self,
value: WebSocketConfig,
) -> WebSocketClientEpochBuilder<SetConfig<S>>where
S::Config: IsUnset,
Required.
Sourcepub fn epoch_handler(
self,
value: EpochMessageHandler,
) -> WebSocketClientEpochBuilder<SetEpochHandler<S>>where
S::EpochHandler: IsUnset,
pub fn epoch_handler(
self,
value: EpochMessageHandler,
) -> WebSocketClientEpochBuilder<SetEpochHandler<S>>where
S::EpochHandler: IsUnset,
Required.
Sourcepub fn ping_handler(
self,
value: PingHandler,
) -> WebSocketClientEpochBuilder<SetPingHandler<S>>where
S::PingHandler: IsUnset,
pub fn ping_handler(
self,
value: PingHandler,
) -> WebSocketClientEpochBuilder<SetPingHandler<S>>where
S::PingHandler: IsUnset,
Sourcepub fn maybe_ping_handler(
self,
value: Option<PingHandler>,
) -> WebSocketClientEpochBuilder<SetPingHandler<S>>where
S::PingHandler: IsUnset,
pub fn maybe_ping_handler(
self,
value: Option<PingHandler>,
) -> WebSocketClientEpochBuilder<SetPingHandler<S>>where
S::PingHandler: IsUnset,
Sourcepub fn epoch_ping_handler(
self,
value: EpochPingHandler,
) -> WebSocketClientEpochBuilder<SetEpochPingHandler<S>>where
S::EpochPingHandler: IsUnset,
pub fn epoch_ping_handler(
self,
value: EpochPingHandler,
) -> WebSocketClientEpochBuilder<SetEpochPingHandler<S>>where
S::EpochPingHandler: IsUnset,
Sourcepub fn maybe_epoch_ping_handler(
self,
value: Option<EpochPingHandler>,
) -> WebSocketClientEpochBuilder<SetEpochPingHandler<S>>where
S::EpochPingHandler: IsUnset,
pub fn maybe_epoch_ping_handler(
self,
value: Option<EpochPingHandler>,
) -> WebSocketClientEpochBuilder<SetEpochPingHandler<S>>where
S::EpochPingHandler: IsUnset,
Sourcepub fn keyed_quotas(
self,
value: Vec<(String, Quota)>,
) -> WebSocketClientEpochBuilder<SetKeyedQuotas<S>>where
S::KeyedQuotas: IsUnset,
pub fn keyed_quotas(
self,
value: Vec<(String, Quota)>,
) -> WebSocketClientEpochBuilder<SetKeyedQuotas<S>>where
S::KeyedQuotas: IsUnset,
Sourcepub fn maybe_keyed_quotas(
self,
value: Option<Vec<(String, Quota)>>,
) -> WebSocketClientEpochBuilder<SetKeyedQuotas<S>>where
S::KeyedQuotas: IsUnset,
pub fn maybe_keyed_quotas(
self,
value: Option<Vec<(String, Quota)>>,
) -> WebSocketClientEpochBuilder<SetKeyedQuotas<S>>where
S::KeyedQuotas: IsUnset,
Sourcepub fn default_quota(
self,
value: Quota,
) -> WebSocketClientEpochBuilder<SetDefaultQuota<S>>where
S::DefaultQuota: IsUnset,
pub fn default_quota(
self,
value: Quota,
) -> WebSocketClientEpochBuilder<SetDefaultQuota<S>>where
S::DefaultQuota: IsUnset,
Sourcepub fn maybe_default_quota(
self,
value: Option<Quota>,
) -> WebSocketClientEpochBuilder<SetDefaultQuota<S>>where
S::DefaultQuota: IsUnset,
pub fn maybe_default_quota(
self,
value: Option<Quota>,
) -> WebSocketClientEpochBuilder<SetDefaultQuota<S>>where
S::DefaultQuota: IsUnset,
Sourcepub fn rate_limiter(
self,
value: Arc<RateLimiter<Ustr, MonotonicClock>>,
) -> WebSocketClientEpochBuilder<SetRateLimiter<S>>where
S::RateLimiter: IsUnset,
pub fn rate_limiter(
self,
value: Arc<RateLimiter<Ustr, MonotonicClock>>,
) -> WebSocketClientEpochBuilder<SetRateLimiter<S>>where
S::RateLimiter: IsUnset,
Sourcepub fn maybe_rate_limiter(
self,
value: Option<Arc<RateLimiter<Ustr, MonotonicClock>>>,
) -> WebSocketClientEpochBuilder<SetRateLimiter<S>>where
S::RateLimiter: IsUnset,
pub fn maybe_rate_limiter(
self,
value: Option<Arc<RateLimiter<Ustr, MonotonicClock>>>,
) -> WebSocketClientEpochBuilder<SetRateLimiter<S>>where
S::RateLimiter: IsUnset,
Sourcepub fn state_sink(
self,
value: SocketStateSink,
) -> WebSocketClientEpochBuilder<SetStateSink<S>>where
S::StateSink: IsUnset,
pub fn state_sink(
self,
value: SocketStateSink,
) -> WebSocketClientEpochBuilder<SetStateSink<S>>where
S::StateSink: IsUnset,
Sourcepub fn maybe_state_sink(
self,
value: Option<SocketStateSink>,
) -> WebSocketClientEpochBuilder<SetStateSink<S>>where
S::StateSink: IsUnset,
pub fn maybe_state_sink(
self,
value: Option<SocketStateSink>,
) -> WebSocketClientEpochBuilder<SetStateSink<S>>where
S::StateSink: IsUnset,
Sourcepub fn connection_rate_limiter(
self,
value: Arc<RateLimiter<Ustr, MonotonicClock>>,
) -> WebSocketClientEpochBuilder<SetConnectionRateLimiter<S>>where
S::ConnectionRateLimiter: IsUnset,
pub fn connection_rate_limiter(
self,
value: Arc<RateLimiter<Ustr, MonotonicClock>>,
) -> WebSocketClientEpochBuilder<SetConnectionRateLimiter<S>>where
S::ConnectionRateLimiter: IsUnset,
Sourcepub fn maybe_connection_rate_limiter(
self,
value: Option<Arc<RateLimiter<Ustr, MonotonicClock>>>,
) -> WebSocketClientEpochBuilder<SetConnectionRateLimiter<S>>where
S::ConnectionRateLimiter: IsUnset,
pub fn maybe_connection_rate_limiter(
self,
value: Option<Arc<RateLimiter<Ustr, MonotonicClock>>>,
) -> WebSocketClientEpochBuilder<SetConnectionRateLimiter<S>>where
S::ConnectionRateLimiter: IsUnset,
Sourcepub fn connection_rate_keys(
self,
value: Arc<[Ustr]>,
) -> WebSocketClientEpochBuilder<SetConnectionRateKeys<S>>where
S::ConnectionRateKeys: IsUnset,
pub fn connection_rate_keys(
self,
value: Arc<[Ustr]>,
) -> WebSocketClientEpochBuilder<SetConnectionRateKeys<S>>where
S::ConnectionRateKeys: IsUnset,
Sourcepub fn maybe_connection_rate_keys(
self,
value: Option<Arc<[Ustr]>>,
) -> WebSocketClientEpochBuilder<SetConnectionRateKeys<S>>where
S::ConnectionRateKeys: IsUnset,
pub fn maybe_connection_rate_keys(
self,
value: Option<Arc<[Ustr]>>,
) -> WebSocketClientEpochBuilder<SetConnectionRateKeys<S>>where
S::ConnectionRateKeys: IsUnset,
Sourcepub fn initial_connect_retry_policy(
self,
value: InitialConnectRetryPolicy,
) -> WebSocketClientEpochBuilder<SetInitialConnectRetryPolicy<S>>where
S::InitialConnectRetryPolicy: IsUnset,
pub fn initial_connect_retry_policy(
self,
value: InitialConnectRetryPolicy,
) -> WebSocketClientEpochBuilder<SetInitialConnectRetryPolicy<S>>where
S::InitialConnectRetryPolicy: IsUnset,
Sourcepub fn maybe_initial_connect_retry_policy(
self,
value: Option<InitialConnectRetryPolicy>,
) -> WebSocketClientEpochBuilder<SetInitialConnectRetryPolicy<S>>where
S::InitialConnectRetryPolicy: IsUnset,
pub fn maybe_initial_connect_retry_policy(
self,
value: Option<InitialConnectRetryPolicy>,
) -> WebSocketClientEpochBuilder<SetInitialConnectRetryPolicy<S>>where
S::InitialConnectRetryPolicy: IsUnset,
Sourcepub fn cancellation_token(
self,
value: CancellationToken,
) -> WebSocketClientEpochBuilder<SetCancellationToken<S>>where
S::CancellationToken: IsUnset,
pub fn cancellation_token(
self,
value: CancellationToken,
) -> WebSocketClientEpochBuilder<SetCancellationToken<S>>where
S::CancellationToken: IsUnset,
Sourcepub fn maybe_cancellation_token(
self,
value: Option<CancellationToken>,
) -> WebSocketClientEpochBuilder<SetCancellationToken<S>>where
S::CancellationToken: IsUnset,
pub fn maybe_cancellation_token(
self,
value: Option<CancellationToken>,
) -> WebSocketClientEpochBuilder<SetCancellationToken<S>>where
S::CancellationToken: IsUnset,
Auto Trait Implementations§
impl<S = Empty> !RefUnwindSafe for WebSocketClientEpochBuilder<S>
impl<S = Empty> !UnwindSafe for WebSocketClientEpochBuilder<S>
impl<S> Freeze for WebSocketClientEpochBuilder<S>
impl<S> Send for WebSocketClientEpochBuilder<S>
impl<S> Sync for WebSocketClientEpochBuilder<S>
impl<S> Unpin for WebSocketClientEpochBuilder<S>
impl<S> UnsafeUnpin for WebSocketClientEpochBuilder<S>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more