Macro datafusion::physical_plan::handle_async_state

macro_rules! handle_async_state {
    ($state_func:expr, $cx:expr) => { ... };
}

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 a Result<StatefulStreamResult<_>>.
• $cx: The context to be passed for polling, usually of type &mut Context.