Run cargo fmt

Author: kisakishy

examples/http-multi-server-channels/src/main.rs

@@ -6,11 +6,7 @@ use axum::{
     routing::post,
 };
 use clap::Parser;
-use polytune::{
-    channel::Channel,
-    garble_lang::compile,
-    mpc,
-};
+use polytune::{channel::Channel, garble_lang::compile, mpc};
 use reqwest::StatusCode;
 use std::{net::SocketAddr, path::PathBuf, result::Result, time::Duration};
 use tokio::{

examples/http-single-server-channels/src/http_channel.rs

@@ -73,11 +73,7 @@ impl Channel for PollingHttpChannel {
         }
     }
 
-    async fn recv_bytes_from(
-        &self,
-        p: usize,
-        _phase: &str,
-    ) -> Result<Vec<u8>, HttpChannelError> {
+    async fn recv_bytes_from(&self, p: usize, _phase: &str) -> Result<Vec<u8>, HttpChannelError> {
         let url = format!("{}/recv/{}/{}/{}", self.url, self.session, p, self.party);
         let mut attempts = 0;
         loop {

src/channel.rs

@@ -82,11 +82,7 @@ pub trait Channel {
 
     /// Awaits a response from the party with the given index (must be between `0..participants`).
     #[allow(async_fn_in_trait)]
-    async fn recv_bytes_from(
-        &self,
-        party: usize,
-        phase: &str,
-    ) -> Result<Vec<u8>, Self::RecvError>;
+    async fn recv_bytes_from(&self, party: usize, phase: &str) -> Result<Vec<u8>, Self::RecvError>;
 }
 
 /// Serializes and sends an MPC message to the other party.