Struct BoxedStreamsClient 

pub struct BoxedStreamsClient<C> { /* private fields */ }

Implementations

impl<C> BoxedStreamsClient<C>

pub fn new(inner: C) -> Self

pub fn inner(&self) -> &C

Trait Implementations

impl<C: Clone> Clone for BoxedStreamsClient<C>

fn clone(&self) -> BoxedStreamsClient<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for BoxedStreamsClient<C>

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

Formats the value using the given formatter.

impl<C: HasStats> HasStats for BoxedStreamsClient<C>

fn aggregate_stats(&self) -> AggregateStats

fn mls_stats(&self) -> ApiStats

fn identity_stats(&self) -> IdentityStats

impl<C: IsConnectedCheck> IsConnectedCheck for BoxedStreamsClient<C>

fn is_connected<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if a client is connected

impl<C: XmtpBackendClient> XmtpBackendClient for BoxedStreamsClient<C>

type Error = <C as XmtpBackendClient>::Error

fn publish<'life0, 'async_trait>( &'life0 self, request: PublishRequest, ) -> Pin<Box<dyn Future<Output = Result<PublishResponse, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn query<'life0, 'async_trait>( &'life0 self, request: QueryRequest, ) -> Pin<Box<dyn Future<Output = Result<QueryResponse, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn query_newest<'life0, 'async_trait>( &'life0 self, request: QueryNewestRequest, ) -> Pin<Box<dyn Future<Output = Result<QueryNewestResponse, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_inbox_ids<'life0, 'async_trait>( &'life0 self, request: GetInboxIdsRequest, ) -> Pin<Box<dyn Future<Output = Result<GetInboxIdsResponse, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_configuration<'life0, 'async_trait>( &'life0 self, request: GetConfigurationRequest, ) -> Pin<Box<dyn Future<Output = Result<GetConfigurationResponse, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read what this deployment publishes about itself. Served without a credential, so it is the one call a client can make before it knows whether the deployment requires one.

fn backend_url(&self) -> Option<&str>

The backend URL this client sends to, when the transport knows it.

fn has_credential_source(&self) -> bool

Whether a credential source — an auth callback or an auth handle — was configured on this transport (CFG-062). A transport with no auth middleware reports false and build refuses a deployment that requires authentication. Defaults to true so a test double, which has no transport stack to ask, is never the thing that refuses a build.

fn set_limits(&self, limits: Arc<LimitsConfiguration>)

Install the shapes the deployment publishes (CFG-064), so the stream and metadata chunking that happens below ApiClientWrapper uses them too. Called once, by build, before any stream opens. A transport with nothing to chunk ignores it.

fn verify_smart_contract_wallet_signatures<'life0, 'async_trait>( &'life0 self, request: VerifySmartContractWalletSignaturesRequest, ) -> Pin<Box<dyn Future<Output = Result<VerifySmartContractWalletSignaturesResponse, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn register<'life0, 'async_trait>( &'life0 self, request: RegisterRequest, ) -> Pin<Box<dyn Future<Output = Result<RecipientState, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn unregister<'life0, 'async_trait>( &'life0 self, request: UnregisterRequest, ) -> Pin<Box<dyn Future<Output = Result<UnregisterResponse, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn update_subscriptions<'life0, 'async_trait>( &'life0 self, request: UpdateSubscriptionsRequest, ) -> Pin<Box<dyn Future<Output = Result<RecipientState, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<C> XmtpMlsBidiStreams for BoxedStreamsClient<C>

where C: XmtpMlsBidiStreams,

type SubscribeStream = <C as XmtpMlsBidiStreams>::SubscribeStream

type Error = <C as XmtpMlsBidiStreams>::Error

fn host(&self) -> &str

Return the URL used for bidi connections. Combine it with the API client’s Arc identity when selecting a shared connection.

fn bidi_limits(&self) -> Arc<LimitsConfiguration>

The frame shapes this deployment accepts (CFG-064), as installed by XmtpBackendClient::set_limits. The bidi ledger chunks interest updates below ApiClientWrapper, so it cannot read the wrapper’s copy and asks the transport instead. A transport that was never told reports the compiled defaults.

fn subscribe_bidi<'life0, 'async_trait>( &'life0 self, requests: BoxStream<'static, SubscribeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Self::SubscribeStream, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Open the bidirectional stream. requests is the outbound client→server frame stream (typically fed by a channel; the first frame is an Update naming the initial topic set); the returned stream yields the server→client frames.

impl<C: XmtpMlsStreams> XmtpMlsStreams for BoxedStreamsClient<C>

where C::GroupMessageStream: 'static, C::WelcomeMessageStream: 'static,

type Error = <C as XmtpMlsStreams>::Error

type GroupMessageStream = Pin<Box<dyn Stream<Item = Result<GroupMessage, <C as XmtpMlsStreams>::Error>> + Send>>

type WelcomeMessageStream = Pin<Box<dyn Stream<Item = Result<WelcomeMessage, <C as XmtpMlsStreams>::Error>> + Send>>

fn subscribe_envelopes_with_cursors<'life0, 'life1, 'async_trait>( &'life0 self, cursors: &'life1 TopicCursor, limits: IncomingBatchLimits, ) -> Pin<Box<dyn Future<Output = Result<IncomingSubscription<Self::Error>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribe after committed receipt positions without decoding MLS payloads. Acknowledge new positions only after the raw envelopes commit to storage.

fn subscribe_group_messages<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, groups: &'life1 [&'life2 GroupId], ) -> Pin<Box<dyn Future<Output = Result<Self::GroupMessageStream, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn subscribe_group_messages_with_cursors<'life0, 'life1, 'async_trait>( &'life0 self, groups: &'life1 TopicCursor, ) -> Pin<Box<dyn Future<Output = Result<Self::GroupMessageStream, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn subscribe_welcome_messages<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, installations: &'life1 [&'life2 InstallationId], ) -> Pin<Box<dyn Future<Output = Result<Self::WelcomeMessageStream, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn subscribe_welcome_messages_with_cursors<'life0, 'life1, 'async_trait>( &'life0 self, installations: &'life1 TopicCursor, ) -> Pin<Box<dyn Future<Output = Result<Self::WelcomeMessageStream, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,