Struct Service 

pub struct Service<SinkT, ResponseT, TransportE, TimeoutFut, TimeoutE> {
    pub sink: SinkT,
    pub phantom: PhantomDisown<(ResponseT, TransportE, TimeoutFut, TimeoutE)>,
}

Implementor of Service which dispatches to a Task.

Fields

sink: SinkT

The sink over which to communicate with the Task.

phantom: PhantomDisown<(ResponseT, TransportE, TimeoutFut, TimeoutE)>

Implementations

impl<SinkT, ResponseT, TransportE, TimeoutFut, TimeoutE> Service<SinkT, ResponseT, TransportE, TimeoutFut, TimeoutE>

pub const fn new<RequestT>(sink: SinkT) -> Self

where Self: Service<Notification<RequestT>>,

Trait Implementations

impl<SinkT: Clone, ResponseT, TransportE, TimeoutFut, TimeoutE> Clone for Service<SinkT, ResponseT, TransportE, TimeoutFut, TimeoutE>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<SinkT: Debug, ResponseT: Debug, TransportE: Debug, TimeoutFut: Debug, TimeoutE: Debug> Debug for Service<SinkT, ResponseT, TransportE, TimeoutFut, TimeoutE>

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

Formats the value using the given formatter.

impl<'a, SinkT, SinkE, RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE> Service<Dialogue<RequestT, ResponseT, TimeoutFut>> for &'a Service<SinkT, ResponseT, TransportE, TimeoutFut, TimeoutE>

where &'a SinkT: Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>, Error = SinkE>,

type Response = ResponseT

Responses given by the service.

type Error = Error<SinkE, TransportE, TimeoutE>

Errors produced by the service.

type Future = OneTwo<MapErr<SendAndClose<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>, &'a SinkT>, fn(SinkE) -> Error<SinkE, TransportE, TimeoutE>>, OneTwo<Map<Receiver<TransportE>, fn(Result<TransportE, Canceled>) -> Result<(), Error<SinkE, TransportE, TimeoutE>>>, Map<Receiver<Result<ResponseT, Either<TransportE, TimeoutE>>>, fn(Result<Result<ResponseT, Either<TransportE, TimeoutE>>, Canceled>) -> Result<ResponseT, Error<SinkE, TransportE, TimeoutE>>>>>

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, _: Dialogue<RequestT, ResponseT, TimeoutFut>) -> Self::Future

Process the request and return the response asynchronously.

impl<SinkT, RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE> Service<Dialogue<RequestT, ResponseT, TimeoutFut>> for Service<SinkT, ResponseT, TransportE, TimeoutFut, TimeoutE>

where SinkT: Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>> + Unpin + Clone,

type Response = ResponseT

Responses given by the service.

type Error = Error<<SinkT as Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>>>::Error, TransportE, TimeoutE>

Errors produced by the service.

type Future = OneTwo<MapErr<SendAndClose<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>, SinkT>, fn(<SinkT as Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>>>::Error) -> Error<<SinkT as Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>>>::Error, TransportE, TimeoutE>>, OneTwo<Map<Receiver<TransportE>, fn(Result<TransportE, Canceled>) -> Result<(), Error<<SinkT as Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>>>::Error, TransportE, TimeoutE>>>, Map<Receiver<Result<ResponseT, Either<TransportE, TimeoutE>>>, fn(Result<Result<ResponseT, Either<TransportE, TimeoutE>>, Canceled>) -> Result<ResponseT, Error<<SinkT as Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>>>::Error, TransportE, TimeoutE>>>>>

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, _: Dialogue<RequestT, ResponseT, TimeoutFut>) -> Self::Future

Process the request and return the response asynchronously.

impl<'a, SinkT, SinkE, RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE> Service<Notification<RequestT>> for &'a Service<SinkT, ResponseT, TransportE, TimeoutFut, TimeoutE>

where &'a SinkT: Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>, Error = SinkE>,

type Response = ()

Responses given by the service.

type Error = Error<SinkE, TransportE>

Errors produced by the service.

type Future = OneTwo<MapErr<SendAndClose<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>, &'a SinkT>, fn(SinkE) -> Error<SinkE, TransportE>>, Map<Receiver<TransportE>, fn(Result<TransportE, Canceled>) -> Result<(), Error<SinkE, TransportE>>>>

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, Notification: Notification<RequestT>) -> Self::Future

Process the request and return the response asynchronously.

impl<SinkT, RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE> Service<Notification<RequestT>> for Service<SinkT, ResponseT, TransportE, TimeoutFut, TimeoutE>

where SinkT: Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>> + Unpin + Clone,

type Response = ()

Responses given by the service.

type Error = Error<<SinkT as Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>>>::Error, TransportE>

Errors produced by the service.

type Future = OneTwo<MapErr<SendAndClose<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>, SinkT>, fn(<SinkT as Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>>>::Error) -> Error<<SinkT as Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>>>::Error, TransportE>>, Map<Receiver<TransportE>, fn(Result<TransportE, Canceled>) -> Result<(), Error<<SinkT as Sink<Ask<RequestT, ResponseT, TransportE, TimeoutFut, TimeoutE>>>::Error, TransportE>>>>

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, Notification: Notification<RequestT>) -> Self::Future

Process the request and return the response asynchronously.