fmt

Author: noot

src/pipelines/events.rs

@@ -29,7 +29,9 @@ impl<P: Platform> EventsBus<P> {
 	}
 
 	/// Returns a stream that yields events of type `E`.
-	pub(super) fn subscribe<E>(&self) -> impl Stream<Item = E> + Send + Sync + 'static
+	pub(super) fn subscribe<E>(
+		&self,
+	) -> impl Stream<Item = E> + Send + Sync + 'static
 	where
 		E: Clone + Any + Send + Sync + 'static,
 	{

src/pipelines/exec/scope.rs

@@ -70,7 +70,10 @@ pub(crate) struct RootScope<P: Platform> {
 
 impl<P: Platform> RootScope<P> {
 	/// Initialize all scopes in a given top-level pipeline.
-	pub(crate) fn new(pipeline: &Pipeline<P>, init_checkpoint: &Checkpoint<P>) -> Self {
+	pub(crate) fn new(
+		pipeline: &Pipeline<P>,
+		init_checkpoint: &Checkpoint<P>,
+	) -> Self {
 		let current = RefCell::new(StepPath::empty());
 		let root = Scope::rooted_at(pipeline, init_checkpoint);
 		let root = RwLock::new(root);

src/pipelines/service.rs

@@ -117,7 +117,9 @@ where
 		&self.provider
 	}
 
-	pub(super) const fn node_config(&self) -> &NodeConfig<types::ChainSpec<Plat>> {
+	pub(super) const fn node_config(
+		&self,
+	) -> &NodeConfig<types::ChainSpec<Plat>> {
 		&self.node_config
 	}
 

src/pipelines/step/instance.rs

@@ -261,7 +261,10 @@ impl<P: Platform> StepInstance<P> {
 
 	/// This is invoked exactly once when a pipeline is instantiated as a payload
 	/// builder service.
-	pub(crate) fn setup(&self, ctx: InitContext<P>) -> Result<(), PayloadBuilderError> {
+	pub(crate) fn setup(
+		&self,
+		ctx: InitContext<P>,
+	) -> Result<(), PayloadBuilderError> {
 		(self.setup_fn)(&self.instance, ctx)
 	}
 

src/pool/host.rs

@@ -145,7 +145,9 @@ impl<P: Platform> HostNode<P> {
 
 #[cfg(feature = "test-utils")]
 impl<P: PlatformWithRpcTypes> HostNode<P> {
-	pub(crate) fn attach_to_test_node<C: crate::test_utils::ConsensusDriver<P>>(
+	pub(crate) fn attach_to_test_node<
+		C: crate::test_utils::ConsensusDriver<P>,
+	>(
 		self: &Arc<Self>,
 		node: &crate::test_utils::LocalNode<P, C>,
 		order_pool: OrderPool<P>,

src/pool/setup.rs

@@ -141,7 +141,10 @@ struct SystemPoolWrapper<P: Platform, Builder> {
 }
 
 impl<P: Platform, Builder> SystemPoolWrapper<P, Builder> {
-	pub(crate) fn new<Node>(builder: Builder, order_pool: Arc<OrderPoolInner<P>>) -> Self
+	pub(crate) fn new<Node>(
+		builder: Builder,
+		order_pool: Arc<OrderPoolInner<P>>,
+	) -> Self
 	where
 		Builder: PoolBuilderBounds<P, Node>,
 		Node: FullNodeTypes<Types: NodeTypes<Primitives = types::Primitives<P>>>,