Trait Service 

pub trait Service<Request> {
    type QueryResponse: Send + 'static;
    type OnQueryFuture: Future<Output = Option<Self::QueryResponse>> + Send + 'static;
    type OnMessageFuture: Future<Output = ()> + Send + 'static;

    // Required methods
    fn on_query(&self, req: Request) -> Self::OnQueryFuture;
    fn on_message(&self, req: Request) -> Self::OnMessageFuture;
}

Required Associated Types

type QueryResponse: Send + 'static

type OnQueryFuture: Future<Output = Option<Self::QueryResponse>> + Send + 'static

type OnMessageFuture: Future<Output = ()> + Send + 'static

Required Methods

fn on_query(&self, req: Request) -> Self::OnQueryFuture

Called when a query is received.

Returns a future that resolves to the either response to the query if Some, or cancellation of the query if None.

fn on_message(&self, req: Request) -> Self::OnMessageFuture

Called when a message is received.

Implementations on Foreign Types

impl<'a, S, Request> Service<Request> for &'a S

where S: Service<Request> + Sync + 'a,

type QueryResponse = <S as Service<Request>>::QueryResponse

type OnQueryFuture = <S as Service<Request>>::OnQueryFuture

type OnMessageFuture = <S as Service<Request>>::OnMessageFuture

fn on_query(&self, req: Request) -> Self::OnQueryFuture

fn on_message(&self, req: Request) -> Self::OnMessageFuture

impl<S, Request> Service<Request> for Box<S>

where S: Service<Request> + ?Sized,

type QueryResponse = <S as Service<Request>>::QueryResponse

type OnQueryFuture = <S as Service<Request>>::OnQueryFuture

type OnMessageFuture = <S as Service<Request>>::OnMessageFuture

fn on_query(&self, req: Request) -> Self::OnQueryFuture

fn on_message(&self, req: Request) -> Self::OnMessageFuture

impl<S, Request> Service<Request> for Arc<S>

where S: Service<Request> + Sync + ?Sized,

type QueryResponse = <S as Service<Request>>::QueryResponse

type OnQueryFuture = <S as Service<Request>>::OnQueryFuture

type OnMessageFuture = <S as Service<Request>>::OnMessageFuture

fn on_query(&self, req: Request) -> Self::OnQueryFuture

fn on_message(&self, req: Request) -> Self::OnMessageFuture

Implementors

impl Service<ServiceRequest> for DhtService

type QueryResponse = Response

type OnQueryFuture = Ready<Option<<DhtService as Service<ServiceRequest>>::QueryResponse>>

type OnMessageFuture = Ready<()>

impl Service<ServiceRequest> for OverlayService

type QueryResponse = Response

type OnQueryFuture = BoxFutureOrNoop<Option<<OverlayService as Service<ServiceRequest>>::QueryResponse>>

type OnMessageFuture = BoxFutureOrNoop<()>

impl<Request, Q> Service<Request> for BoxCloneService<Request, Q>

where Request: Send + 'static, Q: Send + 'static,

type QueryResponse = Q

type OnQueryFuture = Pin<Box<dyn Future<Output = Option<Q>> + Send>>

type OnMessageFuture = Pin<Box<dyn Future<Output = ()> + Send>>

impl<Request, Q> Service<Request> for BoxService<Request, Q>

where Request: Send + 'static, Q: Send + 'static,

type QueryResponse = Q

type OnQueryFuture = Pin<Box<dyn Future<Output = Option<Q>> + Send>>

type OnMessageFuture = Pin<Box<dyn Future<Output = ()> + Send>>

impl<Request, Q> Service<Request> for Router<Request, Q>

where Request: Send + AsRef<[u8]> + 'static, Q: Send + 'static,

type QueryResponse = Q

type OnQueryFuture = BoxFutureOrNoop<Option<<Router<Request, Q> as Service<Request>>::QueryResponse>>

type OnMessageFuture = BoxFutureOrNoop<()>

impl<Request, Q, T, F> Service<Request> for ServiceMessageFn<Q, T>

where Q: Send + 'static, T: Fn(Request) -> F + Send + 'static, F: Future<Output = ()> + Send + 'static,

type QueryResponse = Q

type OnQueryFuture = Ready<Option<Q>>

type OnMessageFuture = F

impl<Request, Q, T, F> Service<Request> for ServiceQueryFn<T>

where Q: Send + 'static, T: Fn(Request) -> F + Send + 'static, F: Future<Output = Option<Q>> + Send + 'static,

type QueryResponse = Q

type OnQueryFuture = F

type OnMessageFuture = Ready<()>