Struct StreamForwardService

#[non_exhaustive]
pub struct StreamForwardService;

A proxy Service which takes a ProxyRequest and copies the bytes of both the source and target Streams bidirectionally.

Implementations

impl StreamForwardService

pub fn new() -> StreamForwardService

Create a new StreamForwardService.

Trait Implementations

impl Clone for StreamForwardService

fn clone(&self) -> StreamForwardService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamForwardService

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

Formats the value using the given formatter.

impl Default for StreamForwardService

fn default() -> StreamForwardService

Returns the “default value” for a type.

impl<S, T> Service<ProxyRequest<S, T>> for StreamForwardService

where S: Stream + Unpin, T: Stream + Unpin,

type Response = ()

The type of response returned by the service.

type Error = OpaqueError

The type of error returned by the service.

async fn serve( &self, _ctx: Context, __arg2: ProxyRequest<S, T>, ) -> Result<<StreamForwardService as Service<ProxyRequest<S, T>>>::Response, <StreamForwardService as Service<ProxyRequest<S, T>>>::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.