Function test_coprocessor::util::handle_streaming_select

pub fn handle_streaming_select<E, F>(
    copr: &Endpoint<E>, 
    req: Request, 
    check_range: F
) -> Vec<StreamResponse> where
    E: Engine,
    F: FnMut(&Response) + Send + 'static,