Trait volo_grpc::request::IntoStreamingRequest

source · 
pub trait IntoStreamingRequest: Sealed {
    type Stream: Stream<Item = Self::Message> + Send + Sync + 'static;
    type Message;

    // Required method
    fn into_streaming_request(self) -> Request<Self::Stream>;
}

Required Associated Types§

source

type Stream: Stream<Item = Self::Message> + Send + Sync + 'static

The RPC request stream type

source

type Message

The RPC request type

Required Methods§

source

fn into_streaming_request(self) -> Request<Self::Stream>

Wrap the stream of messages in a volo_grpc::Request

Implementors§

source§

impl<T> IntoStreamingRequest for Request<T>
where T: Stream + Send + Sync + 'static,

§

type Stream = T

§

type Message = <T as Stream>::Item

source§

impl<T> IntoStreamingRequest for T
where T: Stream + Send + Sync + 'static,

§

type Stream = T

§

type Message = <T as Stream>::Item