Struct ServiceBackend 

pub struct ServiceBackend { /* private fields */ }

Available on crate feature tower only.

Wraps Tower Service stacks as an HttpBackend.

Both buffered and streaming paths run through Tower middleware when configured via ClientBuilder::transport_stack.

Implementations

impl ServiceBackend

pub fn new<B, S>(buffered: B, streaming: S) -> Self

where B: Service<HttpRequest, Response = HttpResponse, Error = Error> + Clone + Send + 'static, B::Future: Send + 'static, S: Service<HttpRequest, Response = HttpStreamingResponse, Error = Error> + Clone + Send + 'static, S::Future: Send + 'static,

Wraps buffered and streaming Tower services.

pub fn from_boxes( buffered: BoxHttpService, streaming: BoxStreamingHttpService, ) -> Self

Wraps already-boxed buffered and streaming transport stacks.

pub fn buffered_with_reqwest_streaming<S>(service: S, client: Client) -> Self

where S: Service<HttpRequest, Response = HttpResponse, Error = Error> + Clone + Send + 'static, S::Future: Send + 'static,

Buffered Tower stack + plain reqwest streaming (legacy).

pub fn new_buffered_only<S>(service: S, client: Client) -> Self

where S: Service<HttpRequest, Response = HttpResponse, Error = Error> + Clone + Send + 'static, S::Future: Send + 'static,

👎Deprecated:

use from_boxes or transport_stack which wires both paths

Wraps a Tower service and a reqwest backend used for streaming responses.

pub fn from_box(service: BoxHttpService, client: Client) -> Self

👎Deprecated:

use from_boxes

Wraps an already-boxed transport stack with reqwest-only streaming.

pub fn clone_inner(&self) -> BoxHttpService

Returns a clone of the inner transport stack (for advanced testing).

Trait Implementations

impl Clone for ServiceBackend

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl HttpBackend for ServiceBackend

fn execute<'life0, 'async_trait>( &'life0 self, request: HttpRequest, ) -> Pin<Box<dyn Future<Output = Result<HttpResponse>> + Send + 'async_trait>>

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

Executes one HTTP request and returns the fully buffered response.

fn execute_stream<'life0, 'async_trait>( &'life0 self, request: HttpRequest, ) -> Pin<Box<dyn Future<Output = Result<HttpStreamingResponse>> + Send + 'async_trait>>

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

Executes one HTTP request and returns a streaming response body.