tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-09-07 00:00:08 +02:00
Code Issues Packages Projects Releases Wiki Activity

task: add JoinSet::poll_join_next (#5721)

Browse Source
This commit is contained in:
nvartolomei
2023-06-10 13:19:07 +02:00
committed by GitHub
parent e63d0f10bf
commit 7ccd3e0c6d
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio/src/task/join_set.rs
+3 -2
View File
@@ -362,7 +362,7 @@ impl<T: 'static> JoinSet<T> {
/// This can happen if the [coop budget] is reached. /// This can happen if the [coop budget] is reached.
/// ///
/// [coop budget]: crate::task#cooperative-scheduling /// [coop budget]: crate::task#cooperative-scheduling
fn poll_join_next(&mut self, cx: &mut Context<'_>) -> Poll<Option<Result<T, JoinError>>> { pub fn poll_join_next(&mut self, cx: &mut Context<'_>) -> Poll<Option<Result<T, JoinError>>> {
// The call to `pop_notified` moves the entry to the `idle` list. It is moved back to // The call to `pop_notified` moves the entry to the `idle` list. It is moved back to
// the `notified` list if the waker is notified in the `poll` call below. // the `notified` list if the waker is notified in the `poll` call below.
let mut entry = match self.inner.pop_notified(cx.waker()) { let mut entry = match self.inner.pop_notified(cx.waker()) {
@@ -419,7 +419,8 @@ impl<T: 'static> JoinSet<T> {
/// [coop budget]: crate::task#cooperative-scheduling /// [coop budget]: crate::task#cooperative-scheduling
/// [task ID]: crate::task::Id /// [task ID]: crate::task::Id
#[cfg(tokio_unstable)] #[cfg(tokio_unstable)]
fn poll_join_next_with_id( #[cfg_attr(docsrs, doc(cfg(tokio_unstable)))]
pub fn poll_join_next_with_id(
&mut self, &mut self,
cx: &mut Context<'_>, cx: &mut Context<'_>,
) -> Poll<Option<Result<(Id, T), JoinError>>> { ) -> Poll<Option<Result<(Id, T), JoinError>>> {