Trait wasmrs::RSocket

source · 
pub trait RSocket: ConditionallySafe {
    // Required methods
    fn fire_and_forget(&self, payload: RawPayload) -> BoxMono<(), PayloadError>;
    fn request_response(
        &self,
        payload: RawPayload
    ) -> BoxMono<RawPayload, PayloadError>;
    fn request_stream(
        &self,
        payload: RawPayload
    ) -> BoxFlux<RawPayload, PayloadError>;
    fn request_channel(
        &self,
        stream: BoxFlux<RawPayload, PayloadError>
    ) -> BoxFlux<RawPayload, PayloadError>;
}
Expand description

A trait for an RSocket client/server (host/guest).

Required Methods§

source

fn fire_and_forget(&self, payload: RawPayload) -> BoxMono<(), PayloadError>

Fire and Forget interaction model of RSocket.

source

fn request_response( &self, payload: RawPayload ) -> BoxMono<RawPayload, PayloadError>

Request-Response interaction model of RSocket.

source

fn request_stream( &self, payload: RawPayload ) -> BoxFlux<RawPayload, PayloadError>

Request-Stream interaction model of RSocket.

source

fn request_channel( &self, stream: BoxFlux<RawPayload, PayloadError> ) -> BoxFlux<RawPayload, PayloadError>

Request-Channel interaction model of RSocket.

Implementors§