pub async fn try_collect(
    executor: &mut BoxedExecutor
) -> Result<Vec<Tuple>, ExecutorError>