From f618382a0dc85bb25874a6fcd8230dafa526f252 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?H=C3=A9ctor=20Ram=C3=B3n=20Jim=C3=A9nez?= Date: Tue, 4 Mar 2025 19:12:31 +0100 Subject: [PATCH] Run `cargo fmt` --- beacon/src/client.rs | 2 +- beacon/src/stream.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/beacon/src/client.rs b/beacon/src/client.rs index 95755d98..1ca5bc8c 100644 --- a/beacon/src/client.rs +++ b/beacon/src/client.rs @@ -9,8 +9,8 @@ use tokio::net; use tokio::sync::mpsc; use tokio::time; -use std::sync::atomic::{self, AtomicBool}; use std::sync::Arc; +use std::sync::atomic::{self, AtomicBool}; use std::thread; pub const SERVER_ADDRESS: &str = "127.0.0.1:9167"; diff --git a/beacon/src/stream.rs b/beacon/src/stream.rs index 855576e7..68381040 100644 --- a/beacon/src/stream.rs +++ b/beacon/src/stream.rs @@ -1,6 +1,6 @@ +use futures::Future; use futures::channel::mpsc; use futures::stream::{self, Stream, StreamExt}; -use futures::Future; pub fn channel(f: impl Fn(mpsc::Sender) -> F) -> impl Stream where