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