Skip to content

Commit

Permalink
WIP: update test
Browse files Browse the repository at this point in the history
  • Loading branch information
AaronFeickert committed Apr 5, 2023
1 parent f280c31 commit 2a5ec90
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion comms/dht/src/dht.rs
Original file line number Diff line number Diff line change
Expand Up @@ -508,6 +508,7 @@ mod test {
let mut service = dht.inbound_middleware_layer().layer(SinkService::new(out_tx));

let msg = wrap_in_envelope_body!(b"secret".to_vec());
// Don't encrypt
let dht_envelope = make_dht_envelope(
&node_identity,
&msg,
Expand Down Expand Up @@ -540,10 +541,11 @@ mod test {
peer_manager.add_peer(node_identity.to_peer()).await.unwrap();

// Dummy out channel, we are not testing outbound here.
let (out_tx, _out_rx) = mpsc::channel(10);
let (out_tx, _) = mpsc::channel(10);

let shutdown = Shutdown::new();
let dht = Dht::builder()
.local_test()
.with_outbound_sender(out_tx)
.build(
Arc::clone(&node_identity),
Expand Down

0 comments on commit 2a5ec90

Please sign in to comment.