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 36bfee0 commit 7828d0eCopy full SHA for 7828d0e
datafusion/physical-plan/src/stream.rs
@@ -563,12 +563,12 @@ where
563
Box::pin(RecordBatchStreamAdapter::new(schema, emit_stream))
564
}
565
566
-pub(crate) fn spawn_deferred<F, R>(task: F) -> impl Future<Output = Result<R>>
+pub(crate) async fn spawn_deferred<F, R>(task: F) -> Result<R>
567
where
568
F: Future<Output = Result<R>> + Send + 'static,
569
R: Send + 'static,
570
{
571
- async move { SpawnedTask::spawn(task).await? }
+ SpawnedTask::spawn(task).await?
572
573
574
#[cfg(test)]
0 commit comments