Struct DebugIoService 

pub struct DebugIoService<InnerService>
where
    InnerService: Service<(ReadHalf<SimplexStream>, WriteHalf<SimplexStream>), Response = ()> + Clone + Send + 'static,
{ /* private fields */ }

Trait Implementations

impl<InnerService> Clone for DebugIoService<InnerService>

where InnerService: Service<(ReadHalf<SimplexStream>, WriteHalf<SimplexStream>), Response = ()> + Clone + Send + 'static + Clone,

fn clone(&self) -> DebugIoService<InnerService>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<InnerService, Reader, Writer> Service<(Reader, Writer)> for DebugIoService<InnerService>

where InnerService: Service<(ReadHalf<SimplexStream>, WriteHalf<SimplexStream>), Response = ()> + Clone + Send + 'static, InnerService::Future: Future<Output = Result<InnerService::Response, InnerService::Error>> + Send + 'static, InnerService::Error: Send + 'static, Reader: AsyncReadExt + Send + Unpin + 'static, Writer: AsyncWriteExt + Send + Unpin + 'static,

type Response = ()

Responses given by the service.

type Error = <InnerService as Service<(ReadHalf<SimplexStream>, WriteHalf<SimplexStream>)>>::Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<DebugIoService<InnerService> as Service<(Reader, Writer)>>::Response, <DebugIoService<InnerService> as Service<(Reader, Writer)>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call( &mut self, (input_reader, input_writer): (Reader, Writer), ) -> Self::Future

Process the request and return the response asynchronously.