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

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

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

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

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

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

Required methods

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

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

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

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

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

Loading content...

Implementors

impl RSocket for EchoRSocket[src]

impl<R> RSocket for Client<R> where
    R: Send + Sync + Copy + Spawner + 'static, [src]

Loading content...