From 2be8ce6b7cf3c7c4f8d6da4318e728f205586a67 Mon Sep 17 00:00:00 2001 From: Conrad Ludgate Date: Thu, 16 May 2024 21:42:46 +0100 Subject: [PATCH] fmt --- src/concurrent_stream/from_concurrent_stream.rs | 2 +- src/concurrent_stream/try_for_each.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/concurrent_stream/from_concurrent_stream.rs b/src/concurrent_stream/from_concurrent_stream.rs index ac8c106..ab704e9 100644 --- a/src/concurrent_stream/from_concurrent_stream.rs +++ b/src/concurrent_stream/from_concurrent_stream.rs @@ -1,9 +1,9 @@ use super::{ConcurrentStream, Consumer, ConsumerState, IntoConcurrentStream}; -use futures_buffered::FuturesUnordered; #[cfg(all(feature = "alloc", not(feature = "std")))] use alloc::vec::Vec; use core::future::Future; use core::pin::Pin; +use futures_buffered::FuturesUnordered; use futures_lite::StreamExt; use pin_project::pin_project; diff --git a/src/concurrent_stream/try_for_each.rs b/src/concurrent_stream/try_for_each.rs index 13e87ff..63b135d 100644 --- a/src/concurrent_stream/try_for_each.rs +++ b/src/concurrent_stream/try_for_each.rs @@ -1,6 +1,6 @@ use crate::concurrent_stream::ConsumerState; -use futures_buffered::FuturesUnordered; use crate::private::Try; +use futures_buffered::FuturesUnordered; use futures_lite::StreamExt; use pin_project::pin_project;