about summary refs log tree commit diff
path: root/util/src/queue.rs
diff options
context:
space:
mode:
authorVika <vika@fireburn.ru>2025-04-09 23:31:02 +0300
committerVika <vika@fireburn.ru>2025-04-09 23:31:57 +0300
commit8826d9446e6c492db2243b9921e59ce496027bef (patch)
tree63738aa9001cb73b11cb0e974e93129bcdf1adbb /util/src/queue.rs
parent519cadfbb298f50cbf819dde757037ab56e2863e (diff)
downloadkittybox-8826d9446e6c492db2243b9921e59ce496027bef.tar.zst
cargo fmt
Change-Id: I80e81ebba3f0cdf8c094451c9fe3ee4126b8c888
Diffstat (limited to 'util/src/queue.rs')
-rw-r--r--util/src/queue.rs6
1 files changed, 4 insertions, 2 deletions
diff --git a/util/src/queue.rs b/util/src/queue.rs
index edbec86..b32fdc5 100644
--- a/util/src/queue.rs
+++ b/util/src/queue.rs
@@ -1,5 +1,5 @@
-use std::future::Future;
 use futures_util::Stream;
+use std::future::Future;
 use std::pin::Pin;
 use uuid::Uuid;
 
@@ -44,7 +44,9 @@ pub trait JobQueue<T: JobItem>: Send + Sync + Sized + Clone + 'static {
     ///
     /// Note that one item may be returned several times if it is not
     /// marked as done.
-    fn into_stream(self) -> impl Future<Output = Result<JobStream<Self::Job, Self::Error>, Self::Error>> + Send;
+    fn into_stream(
+        self,
+    ) -> impl Future<Output = Result<JobStream<Self::Job, Self::Error>, Self::Error>> + Send;
 }
 
 /// A job description yielded from a job queue.