Function spawn_ingest 

pub fn spawn_ingest<F>(future: F) -> JoinHandle<F::Output> 
where
    F: Future + Send + 'static,
    F::Output: Send + 'static,

Spawn a future and execute it in ingest thread pool.