diff --git a/src/kiwi/src/main.rs b/src/kiwi/src/main.rs index 8e7c21c..3310f1c 100644 --- a/src/kiwi/src/main.rs +++ b/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()?; diff --git a/src/kiwi/src/plugin/wasm/bridge.rs b/src/kiwi/src/plugin/wasm/bridge.rs index 2ce43d4..8e9295c 100644 --- a/src/kiwi/src/plugin/wasm/bridge.rs +++ b/src/kiwi/src/plugin/wasm/bridge.rs @@ -64,11 +64,7 @@ impl From for Auth { impl From 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(), } } } diff --git a/src/kiwi/src/source/kafka.rs b/src/kiwi/src/source/kafka.rs index 2d477a4..690b442 100644 --- a/src/kiwi/src/source/kafka.rs +++ b/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();