Skip to content

Commit

Permalink
deps: update pea2pea
Browse files Browse the repository at this point in the history
  • Loading branch information
niklaslong committed Jan 28, 2022
1 parent 4c7baea commit 3c9e809
Show file tree
Hide file tree
Showing 5 changed files with 13 additions and 13 deletions.
4 changes: 2 additions & 2 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion testing/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ version = "0.1"
version = "1"

[dependencies.pea2pea]
version = "0.29"
version = "0.31"

[dependencies.peak_alloc]
version = "0.1"
Expand Down
8 changes: 4 additions & 4 deletions testing/src/test_node.rs
Original file line number Diff line number Diff line change
Expand Up @@ -114,10 +114,10 @@ impl TestNode {
let pea2pea_node = Pea2PeaNode::new(Some(config)).await.unwrap();
let client_state = Default::default();
let node = Self::new(pea2pea_node, client_state);
node.enable_disconnect();
node.enable_handshake();
node.enable_reading();
node.enable_writing();
node.enable_disconnect().await;
node.enable_handshake().await;
node.enable_reading().await;
node.enable_writing().await;
node
}

Expand Down
6 changes: 3 additions & 3 deletions testing/tests/common/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -57,9 +57,9 @@ pub async fn spawn_test_node_with_nonce(local_nonce: ClientNonce) -> TestNode {
};

let node = TestNode::new(pea2pea_node, client_state);
node.enable_handshake();
node.enable_reading();
node.enable_writing();
node.enable_handshake().await;
node.enable_reading().await;
node.enable_writing().await;
node
}

Expand Down
6 changes: 3 additions & 3 deletions testing/tests/network/manual_testing.rs
Original file line number Diff line number Diff line change
Expand Up @@ -40,9 +40,9 @@ async fn spawn_inert_node_at_port() {
};

let test_node = TestNode::new(Pea2PeaNode::new(Some(config)).await.unwrap(), Default::default());
test_node.enable_handshake();
test_node.enable_reading();
test_node.enable_writing();
test_node.enable_handshake().await;
test_node.enable_reading().await;
test_node.enable_writing().await;
// test_node.run_periodic_tasks();

std::future::pending::<()>().await;
Expand Down

0 comments on commit 3c9e809

Please sign in to comment.