[][src]Function tari_p2p::initialization::initialize_local_test_comms

pub async fn initialize_local_test_comms<TSink, '_>(
    node_identity: Arc<NodeIdentity>,
    connector: InboundDomainConnector<TSink>,
    data_path: &'_ str,
    discovery_request_timeout: Duration,
    seed_peers: Vec<Peer>
) -> Result<(CommsNode, Dht), CommsInitializationError> where
    TSink: Sink<Arc<PeerMessage>> + Unpin + Clone + Send + Sync + 'static,
    TSink::Error: Error + Send + Sync

Initialize Tari Comms configured for tests