arrow_flight

Module streams

Source
Expand description

Structsยง

  • Wrapper around a fallible stream (one that returns errors) that makes it infallible.
  • Wrapper for a tonic response stream that maps errors to FlightError and returns errors from a oneshot channel into the stream.