pub async fn run_batch(
test_duration_secs: u64,
concurrent_requests: usize,
timeout_secs: u64,
cookie_store_enable: bool,
verbose: bool,
should_prevent: bool,
api_endpoints: Vec<ApiEndpoint>,
step_option: Option<StepOption>,
setup_options: Option<Vec<SetupApiEndpoint>>,
assert_channel_buffer_size: usize,
ema_alpha: f64,
) -> BoxStream<'static, Result<Option<BatchResult>, Error>>