Struct StreamingResponse 

pub struct StreamingResponse<T: Send + 'static>(pub GrpcFuture<(Metadata, GrpcStreamWithTrailingMetadata<T>)>);

Streaming response

Tuple Fields

0: GrpcFuture<(Metadata, GrpcStreamWithTrailingMetadata<T>)>

Initial metadata, stream of items followed by trailing metadata

Implementations

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

pub fn new<F>(f: F) -> StreamingResponse<T>

where F: Future<Output = Result<(Metadata, GrpcStreamWithTrailingMetadata<T>)>> + Send + 'static,

pub fn metadata_and_stream_and_trailing_metadata<S, M>( metadata: Metadata, result: S, trailing: M, ) -> StreamingResponse<T>

where S: Stream<Item = Result<T>> + Send + 'static, M: Future<Output = Result<Metadata>> + Send + 'static,

pub fn metadata_and_stream<S>( metadata: Metadata, result: S, ) -> StreamingResponse<T>

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

pub fn no_metadata<S>(s: S) -> StreamingResponse<T>

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

pub fn completed_with_metadata_and_trailing_metadata( metadata: Metadata, r: Vec<T>, trailing: Metadata, ) -> StreamingResponse<T>

pub fn completed_with_metadata( metadata: Metadata, r: Vec<T>, ) -> StreamingResponse<T>

pub fn iter_with_metadata_and_trailing_metadata<I, M>( metadata: Metadata, iter: I, trailing: M, ) -> StreamingResponse<T>

where I: Iterator<Item = T> + Send + 'static, M: Future<Output = Result<Metadata>> + Send + 'static,

pub fn iter_with_metadata<I>( metadata: Metadata, iter: I, ) -> StreamingResponse<T>

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

pub fn completed(r: Vec<T>) -> StreamingResponse<T>

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

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

pub fn empty() -> StreamingResponse<T>

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

Create an error response

pub fn map_items<U, F>(self, f: F) -> StreamingResponse<U>

where U: Send + 'static, F: FnMut(T) -> U + Send + 'static,

pub fn and_then_items<U, F>(self, f: F) -> StreamingResponse<U>

where U: Send + 'static, F: FnMut(T) -> Result<U> + Send + 'static,

pub fn drop_metadata(self) -> GrpcStream<T>

pub fn into_future(self) -> SingleResponse<Vec<T>>

pub fn single(self) -> SingleResponse<T>

Take single element from stream

pub fn collect(self) -> GrpcFuture<(Metadata, Vec<T>, Metadata)>