Skip to content

Commit

Permalink
Run cargo fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
sebastiencs committed Mar 4, 2024
1 parent 797f98c commit 727c0ef
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 9 deletions.
4 changes: 2 additions & 2 deletions node/testing/src/scenarios/driver.rs
Expand Up @@ -21,8 +21,8 @@ use node::p2p::connection::outgoing::P2pConnectionOutgoingInitLibp2pOpts;

#[cfg(not(feature = "p2p-libp2p"))]
use node::p2p::{
MioEvent,
P2pNetworkAuthState, P2pNetworkNoiseState, P2pNetworkNoiseStateInner, P2pNetworkSelectState,
MioEvent, P2pNetworkAuthState, P2pNetworkNoiseState, P2pNetworkNoiseStateInner,
P2pNetworkSelectState,
};

use crate::{cluster::ClusterNodeId, node::RustNodeTestingConfig, scenario::ScenarioStep};
Expand Down
2 changes: 1 addition & 1 deletion p2p/src/channels/rpc/p2p_channels_rpc_actions.rs
Expand Up @@ -93,7 +93,7 @@ impl redux::EnablingCondition<P2pState> for P2pChannelsRpcAction {
false
};
}

state.peers.get(peer_id)
.filter(|p| !p.is_libp2p() || request.kind().supported_by_libp2p())
.and_then(|p| p.status.as_ready())
Expand Down
9 changes: 3 additions & 6 deletions tools/bootstrap-sandbox/src/client.rs
Expand Up @@ -79,12 +79,9 @@ impl Client {

if let (Some(peer_id), Some(stream_id)) = (self.peer, self.stream) {
if let Some(query) = query.take() {
self.swarm.behaviour_mut().query::<M>(
peer_id,
stream_id,
self.id,
query,
)?;
self.swarm
.behaviour_mut()
.query::<M>(peer_id, stream_id, self.id, query)?;
self.id += 1;
}
}
Expand Down

0 comments on commit 727c0ef

Please sign in to comment.