MCPcopy Create free account
hub / github.com/apache/datafusion / join_next

Method join_next

datafusion/common-runtime/src/join_set.rs:118–120  ·  view source on GitHub ↗

[JoinSet::join_next](tokio::task::JoinSet::join_next) - Await the next completed task.

(&mut self)

Source from the content-addressed store, hash-verified

116
117 /// [JoinSet::join_next](tokio::task::JoinSet::join_next) - Await the next completed task.
118 pub async fn join_next(&mut self) -> Option<Result<T, JoinError>> {
119 self.inner.join_next().await
120 }
121
122 /// [JoinSet::try_join_next](tokio::task::JoinSet::try_join_next) - Try to join the next completed task.
123 pub fn try_join_next(&mut self) -> Option<Result<T, JoinError>> {

Callers 15

drain_join_setFunction · 0.80
buildMethod · 0.80
collect_partitionedFunction · 0.80
streaming_aggregate_testFunction · 0.80
group_by_stringsFunction · 0.80
run_innerMethod · 0.80
plan_to_jsonFunction · 0.80
plan_to_csvFunction · 0.80

Calls

no outgoing calls

Tested by 5

streaming_aggregate_testFunction · 0.64
group_by_stringsFunction · 0.64
run_innerMethod · 0.64