Function block_on_ingest 

pub fn block_on_ingest<F: Future>(future: F) -> F::Output

Run a future to complete in ingest thread pool.