Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

TryFlattenUnordered: propagate base stream error #2607

Merged
merged 7 commits into from Mar 10, 2023

Conversation

olegnn
Copy link
Contributor

@olegnn olegnn commented May 31, 2022

Instead of allowing polling of the underlying stream after the error, propagate this error first, and only after it will be received by the caller, allow to continue polling.
The caller then will be able to either continue to poll the stream or abort due to the received error. This behavior is similar to the behavior of try_buffer_unordered.

@olegnn olegnn requested a review from taiki-e as a code owner May 31, 2022 10:28
@olegnn olegnn changed the title FlattenUnordered: immediately propagate base stream errors TryFlattenUnordered: immediately propagate base stream errors May 31, 2022
@olegnn olegnn force-pushed the fu-propagate-base-stream-errors branch from 1f1e522 to 3f5c9a7 Compare May 31, 2022 10:40
@olegnn olegnn marked this pull request as draft May 31, 2022 11:21
@olegnn olegnn force-pushed the fu-propagate-base-stream-errors branch 2 times, most recently from 7d7d45a to c681714 Compare May 31, 2022 11:51
@olegnn olegnn marked this pull request as ready for review May 31, 2022 11:59
@olegnn olegnn changed the title TryFlattenUnordered: immediately propagate base stream errors TryFlattenUnordered: propagate base stream error May 31, 2022
@olegnn olegnn marked this pull request as draft May 31, 2022 21:02
@olegnn olegnn force-pushed the fu-propagate-base-stream-errors branch 8 times, most recently from b19ca3c to f0c1835 Compare June 6, 2022 11:20
@olegnn olegnn force-pushed the fu-propagate-base-stream-errors branch from f0c1835 to b1b2071 Compare June 6, 2022 11:24
@olegnn olegnn marked this pull request as ready for review June 6, 2022 12:05
@olegnn olegnn force-pushed the fu-propagate-base-stream-errors branch from fc18bd9 to c8f4866 Compare June 10, 2022 20:49
Copy link
Member

@taiki-e taiki-e left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks!

@taiki-e taiki-e merged commit 4d68eee into rust-lang:master Mar 10, 2023
@taiki-e taiki-e added the 0.3-backport: pending The maintainer accepted to backport this to the 0.3 branch, but backport has not been done yet. label Mar 10, 2023
olegnn added a commit to olegnn/futures-rs that referenced this pull request Mar 11, 2023
@taiki-e taiki-e added 0.3-backport: completed and removed 0.3-backport: pending The maintainer accepted to backport this to the 0.3 branch, but backport has not been done yet. labels Mar 11, 2023
@taiki-e taiki-e mentioned this pull request Mar 11, 2023
crapStone pushed a commit to Calciumdibromid/CaBr2 that referenced this pull request Mar 15, 2023
This PR contains the following updates:

| Package | Type | Update | Change |
|---|---|---|---|
| [futures](https://rust-lang.github.io/futures-rs) ([source](https://github.com/rust-lang/futures-rs)) | dependencies | patch | `0.3.26` -> `0.3.27` |

---

### Release Notes

<details>
<summary>rust-lang/futures-rs</summary>

### [`v0.3.27`](https://github.com/rust-lang/futures-rs/blob/HEAD/CHANGELOG.md#&#8203;0327---2023-03-11)

[Compare Source](rust-lang/futures-rs@0.3.26...0.3.27)

-   Add `TryFlattenUnordered` ([#&#8203;2577](rust-lang/futures-rs#2577), [#&#8203;2590](rust-lang/futures-rs#2590), [#&#8203;2606](rust-lang/futures-rs#2606), [#&#8203;2607](rust-lang/futures-rs#2607))
-   Add `AbortHandle::is_aborted` ([#&#8203;2710](rust-lang/futures-rs#2710))
-   Add `AbortRegistration::handle` ([#&#8203;2712](rust-lang/futures-rs#2712))
-   Make `BiLock` strict-provenance compatible ([#&#8203;2716](rust-lang/futures-rs#2716))

</details>

---

### Configuration

📅 **Schedule**: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined).

🚦 **Automerge**: Disabled by config. Please merge this manually once you are satisfied.

♻ **Rebasing**: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox.

🔕 **Ignore**: Close this PR and you won't be reminded about this update again.

---

 - [ ] <!-- rebase-check -->If you want to rebase/retry this PR, check this box

---

This PR has been generated by [Renovate Bot](https://github.com/renovatebot/renovate).
<!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiIzNS42LjAiLCJ1cGRhdGVkSW5WZXIiOiIzNS42LjAifQ==-->

Co-authored-by: cabr2-bot <cabr2.help@gmail.com>
Reviewed-on: https://codeberg.org/Calciumdibromid/CaBr2/pulls/1816
Reviewed-by: crapStone <crapstone@noreply.codeberg.org>
Co-authored-by: Calciumdibromid Bot <cabr2_bot@noreply.codeberg.org>
Co-committed-by: Calciumdibromid Bot <cabr2_bot@noreply.codeberg.org>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants