Struct matrix_sdk::futures::SendRequest

pub struct SendRequest<R> { /* private fields */ }

IntoFuture returned by Client::send.

Implementations

impl<R> SendRequest<R>

pub fn with_send_progress_observable( self, send_progress: SharedObservable<TransmissionProgress>, ) -> Self

Replace the default SharedObservable used for tracking upload progress.

Note that any subscribers obtained from subscribe_to_send_progress will be invalidated by this.

pub fn with_homeserver_override( self, homeserver_override: Option<String>, ) -> Self

Replace this request’s target (homeserver) with a custom one.

This is useful at the moment because the current sliding sync implementation uses a proxy server.

pub fn subscribe_to_send_progress(&self) -> Subscriber<TransmissionProgress>

Get a subscriber to observe the progress of sending the request body.

Trait Implementations

impl<R> IntoFuture for SendRequest<R>

where R: OutgoingRequest + Clone + Debug + Send + Sync + 'static, R::IncomingResponse: Send + Sync, HttpError: From<FromHttpResponseError<R::EndpointError>>,

type Output = Result<<R as OutgoingRequest>::IncomingResponse, HttpError>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <SendRequest<R> as IntoFuture>::Output> + Send>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.