Trait dubbo::invocation::IntoStreamingRequest

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

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

Required Associated Types

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

type Message

Required Methods

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

Implementors

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

type Stream = T

type Message = <T as Stream>::Item