fmt

src/kiwi/src/main.rs

@@ -51,7 +51,8 @@ async fn main() -> anyhow::Result<()> {
 
     let pre_forward = config
         .plugins
-        .and_then(|plugins| plugins.pre_forward).map(|path| WasmPlugin::from_file(path).expect("failed to load pre-forward plugin"));
+        .and_then(|plugins| plugins.pre_forward)
+        .map(|path| WasmPlugin::from_file(path).expect("failed to load pre-forward plugin"));
 
     let listen_addr: SocketAddr = config.server.address.parse()?;
 

src/kiwi/src/plugin/wasm/bridge.rs

@@ -64,11 +64,7 @@ impl From<plugin::types::AuthCtx> for Auth {
 impl From<plugin::types::JwtCtx> for Jwt {
     fn from(value: plugin::types::JwtCtx) -> Self {
         Self {
-            claims: value
-                .claims
-                .into_iter()
-                .map(|(k, v)| (k, v))
-                .collect(),
+            claims: value.claims.into_iter().map(|(k, v)| (k, v)).collect(),
         }
     }
 }

src/kiwi/src/source/kafka.rs

@@ -85,7 +85,9 @@ impl LazyKafkaTopicConsumer {
                     tokio::task::yield_now().await;
                 }
                 LazyKafkaTopicConsumerState::Consuming => {
-                    self.inner.subscribe(&[&self.topic]).unwrap_or_else(|_| panic!("failed to subscribe to kafka topic {}", &self.topic));
+                    self.inner.subscribe(&[&self.topic]).unwrap_or_else(|_| {
+                        panic!("failed to subscribe to kafka topic {}", &self.topic)
+                    });
 
                     let mut stream = self.inner.stream();