Struct PendingMorselPlanner 

pub struct PendingMorselPlanner { /* private fields */ }

Wrapper for I/O that must complete before planning can continue.

Implementations

impl PendingMorselPlanner

pub fn new<F>(future: F) -> Self

where F: Future<Output = Result<Box<dyn MorselPlanner>>> + Send + 'static,

Create a new pending planner future.

Example

let work = async move {
 let planner: Box<dyn MorselPlanner> = {
  // Do I/O work here, then return the next planner to run.
  };
  Ok(planner) as Result<_, DataFusionError>;
};
let pending_io = PendingMorselPlanner::new(work);

pub fn into_future(self) -> BoxFuture<'static, Result<Box<dyn MorselPlanner>>>

Consume this wrapper and return the underlying future.

Trait Implementations

impl Future for PendingMorselPlanner

Forwards polling to the underlying future.

type Output = Result<Box<dyn MorselPlanner>, DataFusionError>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.