[−][src]Trait rsocket_rust::prelude::RSocket

pub trait RSocket: Sync + Send {
    pub fn metadata_push(&self, req: Payload) -> Mono<()>;

    pub fn fire_and_forget(&self, req: Payload) -> Mono<()>;

    pub fn request_response(&self, req: Payload) -> Mono<Result<Payload>>;

    pub fn request_stream(&self, req: Payload) -> Flux<Result<Payload>>;

    pub fn request_channel(
        &self, 
        reqs: Flux<Result<Payload>>
    ) -> Flux<Result<Payload>>;
}

Required methods

pub fn metadata_push(&self, req: Payload) -> Mono<()>[src]

pub fn fire_and_forget(&self, req: Payload) -> Mono<()>[src]

pub fn request_response(&self, req: Payload) -> Mono<Result<Payload>>[src]

pub fn request_stream(&self, req: Payload) -> Flux<Result<Payload>>[src]

pub fn request_channel(
    &self,
    reqs: Flux<Result<Payload>>
) -> Flux<Result<Payload>>[src]

Loading content...

Implementors

impl RSocket for EchoRSocket[src]

impl RSocket for Client[src]

Loading content...