fixup! fixup! feat(iota-data-ingestion-core): add README.md

crates/iota-data-ingestion-core/README.md

@@ -98,20 +98,20 @@ The `run()` method is responsible for starting the actor. It creates an [inotify
 
 ```rust
 loop {
-	tokio::select! {
-		// Graceful shutdown
-		_ = &mut self.exit_receiver => break,
-		// Receive from Workers the processed checkpoint sequence numbers, this means that the
-		// files are no longer and a GC can be safely performed
-		Some(gc_checkpoint_number) = self.processed_receiver.recv() => {
-			self.gc_processed_files(gc_checkpoint_number).expect("Failed to clean the directory");
-		}
-	  // `self.sync()` is invoked either after waiting `self.options.tick_interval_ms`
-		// without a new file notification, or immediately upon receiving such a notification.
-		Ok(Some(_)) | Err(_) = timeout(Duration::from_millis(self.options.tick_interval_ms), inotify_recv.recv())  => {
-			self.sync().await.expect("Failed to read checkpoint files");
-		}
-	}
+    tokio::select! {
+        // Graceful shutdown
+        _ = &mut self.exit_receiver => break,
+        // Receive from Workers the processed checkpoint sequence numbers, this means that the
+        // files are no longer and a GC can be safely performed
+        Some(gc_checkpoint_number) = self.processed_receiver.recv() => {
+            self.gc_processed_files(gc_checkpoint_number).expect("Failed to clean the directory");
+        }
+        // `self.sync()` is invoked either after waiting `self.options.tick_interval_ms`
+        // without a new file notification, or immediately upon receiving such a notification.
+        Ok(Some(_)) | Err(_) = timeout(Duration::from_millis(self.options.tick_interval_ms), inotify_recv.recv())  => {
+            self.sync().await.expect("Failed to read checkpoint files");
+        }
+    }
 }
 ```