St: Stream,
St::Item: Future,
{
- pub(super) fn new(stream: St, n: usize) -> Self
- where
- St: Stream,
- St::Item: Future,
- {
+ pub(super) fn new(stream: St, n: usize) -> Self {
Self {
stream: super::Fuse::new(stream),
in_progress_queue: FuturesUnordered::new(),