diff options
Diffstat (limited to 'vendor/futures-util/src/sink/unfold.rs')
| -rw-r--r-- | vendor/futures-util/src/sink/unfold.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/vendor/futures-util/src/sink/unfold.rs b/vendor/futures-util/src/sink/unfold.rs index 330a068c3..dea1307b6 100644 --- a/vendor/futures-util/src/sink/unfold.rs +++ b/vendor/futures-util/src/sink/unfold.rs @@ -73,7 +73,10 @@ where this.state.set(UnfoldState::Value { value: state }); Ok(()) } - Err(err) => Err(err), + Err(err) => { + this.state.set(UnfoldState::Empty); + Err(err) + } } } else { Ok(()) |