Module streams 

FallibleRequestStream and FallibleTonicResponseStream adapters

Re-exports

use crate::error::FlightError; 🔒

use futures::FutureExt; 🔒

use futures::Stream; 🔒

use futures::StreamExt; 🔒

use futures::channel::oneshot::Receiver; 🔒

use futures::channel::oneshot::Sender; 🔒

use std::pin::Pin; 🔒

use std::task::Poll; 🔒

use std::task::ready; 🔒

Structs

FallibleRequestStream

Wrapper around a fallible stream (one that returns errors) that makes it infallible.

FallibleTonicResponseStream 🔒

Wrapper for a tonic response stream that maps errors to FlightError and returns errors from a oneshot channel into the stream.