Function run_test

crates/hyperqueue/src/server/autoalloc/process.rs:2373–2394

(f: F)

    }

    async fn run_test<F: AsyncFnOnce(TestCtx)>(f: F) {
        let _ = env_logger::Builder::default()
            .filter(Some("hyperqueue::server::autoalloc"), LevelFilter::Debug)
            .is_test(true)
            .try_init();

        let state = AutoAllocState::new(1);
        run_server_test(ServerConfigBuilder::default(), |handle| async move {
            let server_ref = handle.server_ref.clone();
            let ctx = TestCtx {
                state,
                senders: AutoallocSenders {
                    server: server_ref,
                    events: EventStreamer::new(None),
                },
                handle,
                workers: Default::default(),
            };
            f(ctx).await;
        })
        .await;
    }

    trait WorkerConfigBuilderExt {
        fn with_manager_info(self, info: ManagerInfo) -> Self;