diff --git a/vicky/src/bin/vicky/events.rs b/vicky/src/bin/vicky/events.rs index e9b25a7..0cc1d3f 100644 --- a/vicky/src/bin/vicky/events.rs +++ b/vicky/src/bin/vicky/events.rs @@ -1,9 +1,8 @@ -use rocket::{get, post, State, serde::json::Json}; +use rocket::response::stream::{Event, EventStream}; +use rocket::{get, post, serde::json::Json, State}; use serde::{Deserialize, Serialize}; -use rocket::response::stream::{EventStream, Event}; use std::time; -use tokio::sync::broadcast::{error::{TryRecvError}, self}; - +use tokio::sync::broadcast::{self, error::TryRecvError}; #[derive(Debug, Clone, PartialEq, Serialize, Deserialize)] #[serde(tag = "type")] diff --git a/vicky/src/lib/logs/mod.rs b/vicky/src/lib/logs/mod.rs index 3e16bdf..39d0acd 100644 --- a/vicky/src/lib/logs/mod.rs +++ b/vicky/src/lib/logs/mod.rs @@ -2,16 +2,9 @@ use std::collections::{HashMap, VecDeque}; use std::time; use rocket::futures::lock::Mutex; -use tokio::sync::broadcast::{ - self, - error::TryRecvError, - Sender, -}; - -use crate::{ - errors::VickyError, - s3::client::S3Client, -}; +use tokio::sync::broadcast::{self, error::TryRecvError, Sender}; + +use crate::{errors::VickyError, s3::client::S3Client}; const LOG_BUFFER: usize = 10000;