Method execute

datafusion/ffi/src/tests/async_provider.rs:203–212

(
        &self,
        _partition: usize,
        _context: Arc<datafusion_execution::TaskContext>,
    )

    }

    fn execute(
        &self,
        _partition: usize,
        _context: Arc<datafusion_execution::TaskContext>,
    ) -> Result<datafusion_execution::SendableRecordBatchStream> {
        Ok(Box::pin(AsyncTestRecordBatchStream {
            batch_request: self.batch_request.clone(),
            batch_receiver: self.batch_receiver.resubscribe(),
        }))
    }
}

impl datafusion_physical_plan::DisplayAs for AsyncTestExecutionPlan {