diff --git a/datafusion/core/src/physical_plan/stream.rs b/datafusion/core/src/physical_plan/stream.rs
index 7834fe54143d6..155da8a8423c5 100644
--- a/datafusion/core/src/physical_plan/stream.rs
+++ b/datafusion/core/src/physical_plan/stream.rs
@@ -81,7 +81,7 @@ impl RecordBatchReceiverStreamBuilder {
     /// retrieved from `Self::tx`
     pub fn spawn_blocking<F>(&mut self, f: F)
     where
-        F: FnOnce() -> (),
+        F: FnOnce(),
         F: Send + 'static,
     {
         self.join_set.spawn_blocking(f);