Struct StreamingRequest 

pub struct StreamingRequest<T: Send + 'static>(pub GrpcStream<T>);

Excluding initial metadata which is passed separately

Tuple Fields

0: GrpcStream<T>

Implementations

impl<T: Send + 'static> StreamingRequest<T>

pub fn new<S>(stream: S) -> StreamingRequest<T>

where S: Stream<Item = Result<T>> + Send + 'static,

pub fn once(item: T) -> StreamingRequest<T>

pub fn iter<I>(iter: I) -> StreamingRequest<T>

where I: IntoIterator<Item = T>, I::IntoIter: Send + 'static,

pub fn mpsc() -> (StreamingRequestSender<T>, StreamingRequest<T>)

pub fn single(item: T) -> StreamingRequest<T>

pub fn empty() -> StreamingRequest<T>

pub fn err(err: Error) -> StreamingRequest<T>