We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bcb61a7 commit c6345f5Copy full SHA for c6345f5
futures-util/src/sink/with_flat_map.rs
@@ -83,11 +83,10 @@ where
83
if buffer.is_some() {
84
ready!(sink.as_mut().poll_ready(cx))?;
85
let item = buffer.take().unwrap();
86
- ready!(Poll::Ready(sink.as_mut().start_send(item)))?;
+ sink.as_mut().start_send(item)?;
87
}
88
if let Some(mut some_stream) = stream.as_mut().as_pin_mut() {
89
- while let Some(x) = ready!(some_stream.as_mut().poll_next(cx)) {
90
- let item = ready!(Poll::Ready(x))?;
+ while let Some(item) = ready!(some_stream.as_mut().poll_next(cx)?) {
91
match sink.as_mut().poll_ready(cx)? {
92
Poll::Ready(()) => sink.as_mut().start_send(item)?,
93
Poll::Pending => {
0 commit comments