From 19871c1924a8569df741d4bf5f63943b6b646c16 Mon Sep 17 00:00:00 2001
From: rtkay123 <dev@kanjala.com>
Date: Thu, 14 Aug 2025 18:33:10 +0200
Subject: feat(config): rule http

---
 crates/router/src/processor.rs | 19 +++++++++++--------
 1 file changed, 11 insertions(+), 8 deletions(-)

(limited to 'crates/router/src/processor.rs')

diff --git a/crates/router/src/processor.rs b/crates/router/src/processor.rs
index b8c69f3..9afe726 100644
--- a/crates/router/src/processor.rs
+++ b/crates/router/src/processor.rs
@@ -1,20 +1,25 @@
 pub mod grpc;
+mod load;
+mod publish;
 mod reload;
 mod route;
-mod publish;
-mod load;
 
 use std::sync::Arc;
 
 use anyhow::Result;
-use async_nats::jetstream::{consumer::{pull, Consumer}, Context};
+use async_nats::jetstream::{
+    Context,
+    consumer::{Consumer, pull},
+};
+use futures_util::StreamExt;
 use tokio::signal;
 use tracing::{error, trace};
 use warden_stack::{Configuration, tracing::SdkTracerProvider};
-use futures_util::StreamExt;
-
-use crate::{cnfg::Nats, state::{AppHandle, AppState, Services}};
 
+use crate::{
+    cnfg::Nats,
+    state::{AppHandle, AppState, Services},
+};
 
 pub async fn serve(
     services: Services,
@@ -31,7 +36,6 @@ pub async fn serve(
     Ok(())
 }
 
-
 async fn run(state: AppHandle) -> anyhow::Result<()> {
     let config = Arc::clone(&state);
     let (consumer, _) = tokio::join!(
@@ -77,7 +81,6 @@ async fn get_or_create_stream(
         .await?)
 }
 
-
 async fn shutdown_signal(provider: SdkTracerProvider) -> Result<()> {
     let ctrl_c = async {
         signal::ctrl_c()
-- 
cgit v1.2.3