Skip to content

Commit 2a5010c

Browse files
committed
fix clippy
1 parent 6891037 commit 2a5010c

File tree

1 file changed

+9
-8
lines changed

1 file changed

+9
-8
lines changed

src/future_queue_grouped.rs

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -28,20 +28,20 @@ pin_project! {
2828
#[pin]
2929
stream: Fuse<St>,
3030
#[pin]
31-
in_progress_queue: PeekableFused<
32-
FuturesUnordered<
33-
FutureWithGW<
34-
<St::Item as GroupedWeightedFuture>::Future,
35-
<St::Item as GroupedWeightedFuture>::Q
36-
>
37-
>
38-
>,
31+
in_progress_queue: PeekableFused<InProgressQueue<St>>,
3932
max_global_weight: usize,
4033
current_global_weight: usize,
4134
group_store: GroupStore<<St::Item as GroupedWeightedFuture>::Q, K, <St::Item as GroupedWeightedFuture>::Future>,
4235
}
4336
}
4437

38+
type InProgressQueue<St> = FuturesUnordered<
39+
FutureWithGW<
40+
<<St as Stream>::Item as GroupedWeightedFuture>::Future,
41+
<<St as Stream>::Item as GroupedWeightedFuture>::Q,
42+
>,
43+
>;
44+
4545
impl<St, K> fmt::Debug for FutureQueueGrouped<St, K>
4646
where
4747
St: Stream + fmt::Debug,
@@ -155,6 +155,7 @@ where
155155
// ---
156156

157157
// This returns true if any new futures were added to the in_progress_queue.
158+
#[allow(clippy::type_complexity)]
158159
fn poll_pop_in_progress(
159160
self: Pin<&mut Self>,
160161
cx: &mut Context<'_>,

0 commit comments

Comments
 (0)