cargo fmt

pallets/ocex/src/lib.rs

@@ -2367,17 +2367,21 @@ impl<T: Config> sp_application_crypto::BoundToRuntimeAppPublic for Pallet<T> {
 impl<T: Config> OneSessionHandler<T::AccountId> for Pallet<T> {
 	type Key = T::AuthorityId;
 
-	fn on_genesis_session<'a, I: 'a + Iterator<Item = (&'a T::AccountId, Self::Key)>>(authorities: I)
-	{
+	fn on_genesis_session<'a, I: 'a + Iterator<Item = (&'a T::AccountId, Self::Key)>>(
+		authorities: I,
+	) {
 		let authorities = authorities.map(|(_, k)| k).collect::<Vec<_>>();
 		<Authorities<T>>::insert(
 			GENESIS_AUTHORITY_SET_ID,
 			ValidatorSet::new(authorities, GENESIS_AUTHORITY_SET_ID),
 		);
 	}
 
-	fn on_new_session<'a, I: 'a + Iterator<Item = (&'a T::AccountId, Self::Key)>>(_changed: bool, authorities: I, queued_authorities: I)
-	{
+	fn on_new_session<'a, I: 'a + Iterator<Item = (&'a T::AccountId, Self::Key)>>(
+		_changed: bool,
+		authorities: I,
+		queued_authorities: I,
+	) {
 		let next_authorities = authorities.map(|(_, k)| k).collect::<Vec<_>>();
 		let next_queued_authorities = queued_authorities.map(|(_, k)| k).collect::<Vec<_>>();
 

pallets/thea/src/session.rs

@@ -28,16 +28,20 @@ impl<T: Config> sp_runtime::BoundToRuntimeAppPublic for Pallet<T> {
 impl<T: Config> OneSessionHandler<T::AccountId> for Pallet<T> {
 	type Key = T::TheaId;
 
-	fn on_genesis_session<'a, I: 'a + Iterator<Item = (&'a T::AccountId, T::TheaId)>>(validators: I)
-	{
+	fn on_genesis_session<'a, I: 'a + Iterator<Item = (&'a T::AccountId, T::TheaId)>>(
+		validators: I,
+	) {
 		let authorities = validators.map(|(_, k)| k).collect::<Vec<_>>();
 		// we panic here as runtime maintainers can simply reconfigure genesis and restart
 		// the chain easily
 		Self::initialize_authorities(&authorities).expect("Authorities vec too big");
 	}
 
-	fn on_new_session<'a, I: 'a + Iterator<Item = (&'a T::AccountId, T::TheaId)>>(_changed: bool, validators: I, queued_validators: I)
-	{
+	fn on_new_session<'a, I: 'a + Iterator<Item = (&'a T::AccountId, T::TheaId)>>(
+		_changed: bool,
+		validators: I,
+		queued_validators: I,
+	) {
 		// A new thea message will be sent on session changes when queued != next.
 		let next_authorities = validators.map(|(_, k)| k).collect::<Vec<_>>();
 		if next_authorities.len() as u32 > T::MaxAuthorities::get() {