alamb commented on code in PR #3594:
URL: https://github.com/apache/arrow-rs/pull/3594#discussion_r1085811226
##########
arrow-flight/src/encode.rs:
##########
@@ -250,9 +280,8 @@ impl Stream for FlightDataEncoder {
None => {
// inner is done
self.done = true;
- // queue must also be empty so we are done
- assert!(self.queue.is_empty());
- return Poll::Ready(None);
+ // queue might still have a message (if the stream
Review Comment:
You are correct it is not needed. I reverted the change in f55ccee9c
--
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]
