Struct grpc::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<Item = (Metadata, GrpcStreamWithTrailingMetadata<T>), Error = Error> + Send + 'static,

pub fn metadata_and_stream_and_trailing_metadata<S, M>(
    metadata: Metadata,
    result: S,
    trailing: M
) -> StreamingResponse<T>where
    S: Stream<Item = T, Error = Error> + Send + 'static,
    M: Future<Item = Metadata, Error = Error> + Send + 'static,

pub fn metadata_and_stream<S>(
    metadata: Metadata,
    result: S
) -> StreamingResponse<T>where
    S: Stream<Item = T, Error = Error> + Send + 'static,

pub fn no_metadata<S>(s: S) -> StreamingResponse<T>where
    S: Stream<Item = T, Error = Error> + 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<Item = Metadata, Error = Error> + 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 wait(
    self
) -> Result<(Metadata, Box<dyn Iterator<Item = Result<T>> + Send>)>

pub fn wait_drop_metadata(self) -> Box<dyn Iterator<Item = Result<T>> + Send>

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