Struct grpc::StreamingRequest
[−]
[src]
pub struct StreamingRequest<T: Send + 'static>(pub GrpcStreamSend<T>);
Excluding initial metadata which is passed separately
Methods
impl<T: Send + 'static> StreamingRequest<T>
[src]
fn new<S>(stream: S) -> StreamingRequest<T> where
S: Stream<Item = T, Error = Error> + Send + 'static,
S: Stream<Item = T, Error = Error> + Send + 'static,
fn once(item: T) -> StreamingRequest<T>
fn iter<I>(iter: I) -> StreamingRequest<T> where
I: IntoIterator<Item = T>,
I::IntoIter: Send + 'static,
I: IntoIterator<Item = T>,
I::IntoIter: Send + 'static,