[−][src]Trait rsocket_rust::prelude::RSocket
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]
&self,
reqs: Flux<Result<Payload>>
) -> Flux<Result<Payload>>
Implementors
impl RSocket for EchoRSocket
[src]
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]
&self,
reqs: Flux<Result<Payload>>
) -> Flux<Result<Payload>>
impl RSocket for Client
[src]
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]
&self,
reqs: Flux<Result<Payload>>
) -> Flux<Result<Payload>>