Trait pubnub_hyper::core::TransportService

pub trait TransportService<Request>: Send {
    type Response;
    type Error;
#[must_use]    fn call<'life0, 'async_trait>(
        &'life0 self, 
        req: Request
    ) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + 'async_trait + Send>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

Service respresents a single unit of an async request/response based API.

Associated Types

type Response

Response given by the service.

type Error

Error produced by the service.

Loading content...

Required methods

#[must_use]fn call<'life0, 'async_trait>(
    &'life0 self,
    req: Request
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Process the request and return the response asynchronously.

Loading content...

Implementors

impl Service<GetState> for MockTransport

type Response = JsonValue

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: GetState
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<GetState>>::Response, <MockTransport as Service<GetState>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<GetState> for Hyper

type Response = GetState

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    request: GetState
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<GlobalHereNow<Full>> for MockTransport

type Response = GlobalInfo<Full>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: GlobalHereNow<Full>
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<GlobalHereNow<Full>>>::Response, <MockTransport as Service<GlobalHereNow<Full>>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<GlobalHereNow<Full>> for Hyper

type Response = GlobalHereNow<Full>

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    _request: GlobalHereNow<Full>
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<GlobalHereNow<OccupancyAndUUIDs>> for MockTransport

type Response = GlobalInfo<OccupancyAndUUIDs>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: GlobalHereNow<OccupancyAndUUIDs>
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<GlobalHereNow<OccupancyAndUUIDs>>>::Response, <MockTransport as Service<GlobalHereNow<OccupancyAndUUIDs>>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<GlobalHereNow<OccupancyAndUUIDs>> for Hyper

type Response = GlobalHereNow<OccupancyAndUUIDs>

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    _request: GlobalHereNow<OccupancyAndUUIDs>
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<GlobalHereNow<OccupancyOnly>> for MockTransport

type Response = GlobalInfo<OccupancyOnly>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: GlobalHereNow<OccupancyOnly>
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<GlobalHereNow<OccupancyOnly>>>::Response, <MockTransport as Service<GlobalHereNow<OccupancyOnly>>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<GlobalHereNow<OccupancyOnly>> for Hyper

type Response = GlobalHereNow<OccupancyOnly>

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    _request: GlobalHereNow<OccupancyOnly>
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<HereNow<Full>> for MockTransport

type Response = <Full as RespondWith>::Response

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: HereNow<Full>
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<HereNow<Full>>>::Response, <MockTransport as Service<HereNow<Full>>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<HereNow<Full>> for Hyper

type Response = HereNow<Full>

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    request: HereNow<Full>
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<HereNow<OccupancyAndUUIDs>> for MockTransport

type Response = <OccupancyAndUUIDs as RespondWith>::Response

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: HereNow<OccupancyAndUUIDs>
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<HereNow<OccupancyAndUUIDs>>>::Response, <MockTransport as Service<HereNow<OccupancyAndUUIDs>>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<HereNow<OccupancyAndUUIDs>> for Hyper

type Response = HereNow<OccupancyAndUUIDs>

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    request: HereNow<OccupancyAndUUIDs>
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<HereNow<OccupancyOnly>> for MockTransport

type Response = <OccupancyOnly as RespondWith>::Response

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: HereNow<OccupancyOnly>
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<HereNow<OccupancyOnly>>>::Response, <MockTransport as Service<HereNow<OccupancyOnly>>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<HereNow<OccupancyOnly>> for Hyper

type Response = HereNow<OccupancyOnly>

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    request: HereNow<OccupancyOnly>
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<Publish> for MockTransport

type Response = Timetoken

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: Publish
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<Publish>>::Response, <MockTransport as Service<Publish>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<Publish> for Hyper

type Response = Publish

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    request: Publish
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<SetState> for MockTransport

type Response = ()

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: SetState
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<SetState>>::Response, <MockTransport as Service<SetState>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<SetState> for Hyper

type Response = SetState

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    request: SetState
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<Subscribe> for MockTransport

type Response = (Vec<Message>, Timetoken)

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: Subscribe
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<Subscribe>>::Response, <MockTransport as Service<Subscribe>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<Subscribe> for Hyper

type Response = Subscribe

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    request: Subscribe
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Service<WhereNow> for MockTransport

type Response = Vec<Name>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: WhereNow
) -> Pin<Box<dyn Future<Output = Result<<MockTransport as Service<WhereNow>>::Response, <MockTransport as Service<WhereNow>>::Error>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    MockTransport: 'async_trait, 

impl Service<WhereNow> for Hyper

type Response = WhereNow

type Error = Error

fn call<'life0, 'async_trait>(
    &'life0 self,
    request: WhereNow
) -> Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Loading content...