Trait rsocket_rust::prelude::RSocket

pub trait RSocket: Sync + Send {
    fn metadata_push(
        &self, 
        req: Payload
    ) -> Box<dyn Future<Item = (), Error = RSocketError>>;
    fn fire_and_forget(
        &self, 
        req: Payload
    ) -> Box<dyn Future<Item = (), Error = RSocketError>>;
    fn request_response(
        &self, 
        req: Payload
    ) -> Box<dyn Future<Item = Payload, Error = RSocketError>>;
    fn request_stream(
        &self, 
        req: Payload
    ) -> Box<dyn Stream<Item = Payload, Error = RSocketError>>;
}

Required methods

fn metadata_push(
    &self,
    req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn fire_and_forget(
    &self,
    req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn request_response(
    &self,
    req: Payload
) -> Box<dyn Future<Item = Payload, Error = RSocketError>>

fn request_stream(
    &self,
    req: Payload
) -> Box<dyn Stream<Item = Payload, Error = RSocketError>>

Loading content...

Implementors

impl RSocket for Client

fn metadata_push(
    &self,
    req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn fire_and_forget(
    &self,
    req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn request_response(
    &self,
    req: Payload
) -> Box<dyn Future<Item = Payload, Error = RSocketError>>

fn request_stream(
    &self,
    req: Payload
) -> Box<dyn Stream<Item = Payload, Error = RSocketError>>

impl RSocket for DuplexSocket

fn metadata_push(
    &self,
    req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn fire_and_forget(
    &self,
    req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn request_response(
    &self,
    input: Payload
) -> Box<dyn Future<Item = Payload, Error = RSocketError>>

fn request_stream(
    &self,
    input: Payload
) -> Box<dyn Stream<Item = Payload, Error = RSocketError>>

impl RSocket for EmptyRSocket

fn metadata_push(
    &self,
    _req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn fire_and_forget(
    &self,
    _req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn request_response(
    &self,
    _req: Payload
) -> Box<dyn Future<Item = Payload, Error = RSocketError>>

fn request_stream(
    &self,
    _req: Payload
) -> Box<dyn Stream<Item = Payload, Error = RSocketError>>

impl RSocket for MockResponder

fn metadata_push(
    &self,
    req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn fire_and_forget(
    &self,
    req: Payload
) -> Box<dyn Future<Item = (), Error = RSocketError>>

fn request_response(
    &self,
    req: Payload
) -> Box<dyn Future<Item = Payload, Error = RSocketError>>

fn request_stream(
    &self,
    req: Payload
) -> Box<dyn Stream<Item = Payload, Error = RSocketError>>

Loading content...