Macro datafusion::physical_plan::handle_async_state
source · macro_rules! handle_async_state { ($state_func:expr, $cx:expr) => { ... }; }
Expand description
The handle_async_state
macro adapts the handle_state
macro for use in
asynchronous operations, particularly when dealing with Poll
results within
async traits like EagerJoinStream
. It polls the asynchronous state-changing
function using poll_unpin
and then passes the result to handle_state
for
further processing.
Arguments
$state_func
: An async function or future that returns aResult<StreamJoinStateResult<_>>
.$cx
: The context to be passed for polling, usually of type&mut Context
.