Module streams

FallibleRequestStream and FallibleTonicResponseStream adapters

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.