alamb commented on code in PR #3464:
URL: https://github.com/apache/arrow-rs/pull/3464#discussion_r1093760417
##########
arrow-flight/src/client.rs:
##########
@@ -531,3 +549,118 @@ impl FlightClient {
request
}
}
+
+/// A stream that reads `Results`, passing along Ok variants,
+/// and saving any Errors seen to be forward along with responses
+///
+/// If the input stream produces an an error, the error is saved in `err`
+/// and this stream is ended (the inner is not pollled any more)
+///
+/// The setup of copying errors to result stream looks like this:
+///
+/// ```text
+/// input: ---> (Stream of Result<FlightData>) ---- (Stream of FlightData)
---- network ----> Server
Review Comment:
I made some ascii art to explain what is happening here
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
