rustfmt

client/network-gossip/src/bridge.rs

@@ -435,9 +435,7 @@ mod tests {
 		}
 	}
 
-	impl NetworkBlock<<Block as BlockT>::Hash, NumberFor<Block>>
-		for TestNetwork
-	{
+	impl NetworkBlock<<Block as BlockT>::Hash, NumberFor<Block>> for TestNetwork {
 		fn announce_block(&self, _hash: <Block as BlockT>::Hash, _data: Option<Vec<u8>>) {
 			unimplemented!();
 		}

client/network-gossip/src/lib.rs

@@ -81,10 +81,7 @@ mod validator;
 
 /// Abstraction over a network.
 pub trait Network<B: BlockT>:
-	NetworkPeers
-	+ NetworkEventStream
-	+ NetworkNotification
-	+ NetworkBlock<B::Hash, NumberFor<B>>
+	NetworkPeers + NetworkEventStream + NetworkNotification + NetworkBlock<B::Hash, NumberFor<B>>
 {
 	fn add_set_reserved(&self, who: PeerId, protocol: ProtocolName) {
 		let addr =

client/network-gossip/src/state_machine.rs

@@ -677,9 +677,7 @@ mod tests {
 		}
 	}
 
-	impl NetworkBlock<<Block as BlockT>::Hash, NumberFor<Block>>
-		for NoOpNetwork
-	{
+	impl NetworkBlock<<Block as BlockT>::Hash, NumberFor<Block>> for NoOpNetwork {
 		fn announce_block(&self, _hash: <Block as BlockT>::Hash, _data: Option<Vec<u8>>) {
 			unimplemented!();
 		}

client/network/common/src/service.rs

@@ -623,8 +623,7 @@ pub trait NetworkBlock<BlockHash, BlockNumber> {
 	fn new_best_block_imported(&self, hash: BlockHash, number: BlockNumber);
 }
 
-impl<T, BlockHash, BlockNumber> NetworkBlock<BlockHash, BlockNumber>
-	for Arc<T>
+impl<T, BlockHash, BlockNumber> NetworkBlock<BlockHash, BlockNumber> for Arc<T>
 where
 	T: ?Sized,
 	T: NetworkBlock<BlockHash, BlockNumber>,

client/network/src/lib.rs

@@ -273,7 +273,7 @@ pub use sc_network_common::{
 	},
 	sync::{
 		warp::{WarpSyncPhase, WarpSyncProgress},
-		StateDownloadProgress, SyncState, 
+		StateDownloadProgress, SyncState,
 	},
 };
 pub use service::{

client/network/sync/src/lib.rs

@@ -1362,7 +1362,7 @@ where
 				},
 				ToServiceCommand::Status { pending_response } => {
 					let _ = pending_response.send(self.status());
-				}
+				},
 			}
 		}
 		self.process_outbound_requests();

client/network/sync/src/service/chain_sync.rs

@@ -36,7 +36,9 @@ pub enum ToServiceCommand<B: BlockT> {
 	),
 	JustificationImported(PeerId, B::Hash, NumberFor<B>, bool),
 	BlockFinalized(B::Hash, NumberFor<B>),
-	Status { pending_response: oneshot::Sender<SyncStatus<B>> },
+	Status {
+		pending_response: oneshot::Sender<SyncStatus<B>>,
+	},
 }
 
 /// Handle for communicating with `ChainSync` asynchronously
@@ -57,7 +59,7 @@ impl<B: BlockT> ChainSyncInterfaceHandle<B> {
 	}
 
 	/// Get sync status
-	/// 
+	///
 	/// Returns an error if `ChainSync` has terminated.
 	pub async fn status(&self) -> Result<SyncStatus<B>, ()> {
 		let (tx, rx) = oneshot::channel();

client/service/src/builder.rs

@@ -962,7 +962,11 @@ where
 		Some("networking"),
 		chain_sync_network_provider.run(network.clone()),
 	);
-	spawn_handle.spawn("import-queue", None, import_queue.run(Box::new(chain_sync_service.clone())));
+	spawn_handle.spawn(
+		"import-queue",
+		None,
+		import_queue.run(Box::new(chain_sync_service.clone())),
+	);
 
 	let (system_rpc_tx, system_rpc_rx) = tracing_unbounded("mpsc_system_rpc", 10_000);
 	spawn_handle.spawn(
@@ -978,7 +982,8 @@ where
 		),
 	);
 
-	let future = build_network_future(network_mut, client, chain_sync_service, config.announce_block);
+	let future =
+		build_network_future(network_mut, client, chain_sync_service, config.announce_block);
 
 	// TODO: Normally, one is supposed to pass a list of notifications protocols supported by the
 	// node through the `NetworkConfiguration` struct. But because this function doesn't know in