Function create_test_server

api/src/tests.rs:188–203

Wrapper around server initialization that handles creating the shutdown handler

(
    node_id: NodeId,
    network: Network,
    interest: I,
    model: Arc<M>,
    p2p: P,
    pipeline: Option<PipelineHandle>,
)

/// Wrapper around server initialization that handles creating the shutdown handler
fn create_test_server<C, I, M, P>(
    node_id: NodeId,
    network: Network,
    interest: I,
    model: Arc<M>,
    p2p: P,
    pipeline: Option<PipelineHandle>,
) -> Server<C, I, M, P>
where
    I: InterestService,
    M: EventService + 'static,
    P: P2PService,
{
    let shutdown = Shutdown::new();
    Server::new(node_id, network, interest, model, p2p, pipeline, shutdown)
}

#[test(tokio::test)]
async fn create_event() {