Trait binate::RSocket

pub trait RSocket: Send + Sync {
    fn request_response(&self, payload: Payload) -> Mono<Result<Payload>>;
    fn request_stream(&self, payload: Payload) -> Flux<Result<Payload>>;
    fn request_channel(
        &self, 
        payloads: Flux<Result<Payload>>
    ) -> Flux<Result<Payload>>;
    fn fire_and_forget(&self, payload: Payload) -> Mono<Result<()>>;
    fn metadata_push(&self, payload: Payload) -> Mono<Result<()>>;
}

A trait that represents a Reactive Socket.

Required methods

fn request_response(&self, payload: Payload) -> Mono<Result<Payload>>

Request-Response interaction model of RSocket.

fn request_stream(&self, payload: Payload) -> Flux<Result<Payload>>

Request-Stream interaction model of RSocket.

fn request_channel(
    &self,
    payloads: Flux<Result<Payload>>
) -> Flux<Result<Payload>>

Request-Channel interaction model of RSocket.

fn fire_and_forget(&self, payload: Payload) -> Mono<Result<()>>

Fire-and-Forget interaction model of RSocket.

fn metadata_push(&self, payload: Payload) -> Mono<Result<()>>

Metadata-Push interaction model of RSocket.

Implementors