Trait pubnub_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>> + Send + 'async_trait>>
    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>> + Send + 'async_trait>> 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 = GetState

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = GlobalHereNow<Full>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = GlobalHereNow<OccupancyAndUUIDs>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = GlobalHereNow<OccupancyOnly>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = HereNow<Full>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = HereNow<OccupancyAndUUIDs>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = HereNow<OccupancyOnly>

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = Publish

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = SetState

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = Subscribe

type Error = MockTransportError

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: 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 = WhereNow

type Error = MockTransportError

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

Loading content...