Struct grpc::StreamingResponse
source · pub struct StreamingResponse<T: Send + 'static>(pub GrpcFuture<(Metadata, GrpcStreamWithTrailingMetadata<T>)>);
Expand description
Streaming response
Tuple Fields
0: GrpcFuture<(Metadata, GrpcStreamWithTrailingMetadata<T>)>
Initial metadata, stream of items followed by trailing metadata
Implementations
sourceimpl<T: Send + 'static> StreamingResponse<T>
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>
sourcepub fn err(err: Error) -> 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>>
sourcepub fn single(self) -> SingleResponse<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)>
Auto Trait Implementations
impl<T> !RefUnwindSafe for StreamingResponse<T>
impl<T> Send for StreamingResponse<T>
impl<T> !Sync for StreamingResponse<T>
impl<T> Unpin for StreamingResponse<T>
impl<T> !UnwindSafe for StreamingResponse<T>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more