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 4562285 commit c3bdf54Copy full SHA for c3bdf54
src/robust_provider/subscription.rs
@@ -240,17 +240,11 @@ impl<N: 'static + Clone + Send + Network> Stream for RobustSubscriptionStream<N>
240
241
fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
242
let (result, rx) = ready!(self.inner.poll(cx));
243
-
+ self.inner.set(make_future(rx));
244
match result {
245
- Ok(item) => {
246
- self.inner.set(make_future(rx));
247
- Poll::Ready(Some(Ok(item)))
248
- }
+ Ok(item) => Poll::Ready(Some(Ok(item))),
249
Err(Error::Closed) => Poll::Ready(None),
250
- Err(e) => {
251
252
- Poll::Ready(Some(Err(e)))
253
+ Err(e) => Poll::Ready(Some(Err(e))),
254
}
255
256
0 commit comments