fix: replace futures dependency with futures-util

Cargo.toml

@@ -47,7 +47,7 @@ time = { version = "0.3.10", features = [
     "serde-human-readable",
     "serde-well-known",
 ] }
-futures = "0.3.21"
+futures-util = "0.3.31"
 ress = "0.11.0"
 phf = "0.11.0"
 phf_codegen = "0.11.0"

cli/Cargo.toml

@@ -45,7 +45,7 @@ rustypipe = { workspace = true, features = ["rss"] }
 rustypipe-downloader.workspace = true
 reqwest.workspace = true
 tokio = { workspace = true, features = ["macros", "rt-multi-thread"] }
-futures.workspace = true
+futures-util.workspace = true
 serde.workspace = true
 serde_json.workspace = true
 

cli/src/main.rs

@@ -10,7 +10,7 @@ use std::{
 
 use clap::{Parser, Subcommand, ValueEnum};
 use const_format::formatcp;
-use futures::stream::{self, StreamExt};
+use futures_util::stream::{self, StreamExt};
 use indicatif::{MultiProgress, ProgressBar, ProgressStyle};
 use owo_colors::OwoColorize;
 use rustypipe::{

codegen/Cargo.toml

@@ -12,7 +12,7 @@ publish = false
 rustypipe = { path = "../" }
 reqwest.workspace = true
 tokio = { workspace = true, features = ["rt-multi-thread"] }
-futures.workspace = true
+futures-util.workspace = true
 serde.workspace = true
 serde_json.workspace = true
 serde_with.workspace = true

codegen/src/abtest.rs

@@ -1,7 +1,7 @@
 use std::collections::BTreeMap;
 
 use anyhow::{bail, Result};
-use futures::{stream, StreamExt};
+use futures_util::{stream, StreamExt};
 use indicatif::{ProgressBar, ProgressStyle};
 use num_enum::TryFromPrimitive;
 use once_cell::sync::Lazy;

codegen/src/collect_album_types.rs

@@ -1,6 +1,6 @@
 use std::{collections::BTreeMap, fs::File, io::BufReader};
 
-use futures::stream::{self, StreamExt};
+use futures_util::stream::{self, StreamExt};
 use path_macro::path;
 use rustypipe::{
     client::{ClientType, RustyPipe, RustyPipeQuery},

codegen/src/collect_large_numbers.rs

@@ -6,7 +6,7 @@ use std::{
 };
 
 use anyhow::{Context, Result};
-use futures::{stream, StreamExt};
+use futures_util::{stream, StreamExt};
 use once_cell::sync::Lazy;
 use path_macro::path;
 use regex::Regex;

codegen/src/collect_playlist_dates.rs

@@ -5,7 +5,7 @@ use std::{
     io::BufReader,
 };
 
-use futures::{stream, StreamExt};
+use futures_util::{stream, StreamExt};
 use ordered_hash_map::OrderedHashMap;
 use path_macro::path;
 use rustypipe::{

codegen/src/collect_video_dates.rs

@@ -3,7 +3,7 @@ use std::{
     fs::File,
 };
 
-use futures::{stream, StreamExt};
+use futures_util::{stream, StreamExt};
 use path_macro::path;
 use rustypipe::{
     client::{RustyPipe, RustyPipeQuery},

codegen/src/collect_video_durations.rs

@@ -5,7 +5,7 @@ use std::{
 };
 
 use anyhow::Result;
-use futures::{stream, StreamExt};
+use futures_util::{stream, StreamExt};
 use path_macro::path;
 use rustypipe::{
     client::{ClientType, RustyPipe, RustyPipeQuery},

downloader/Cargo.toml

@@ -37,7 +37,7 @@ rustypipe.workspace = true
 once_cell.workspace = true
 regex.workspace = true
 thiserror.workspace = true
-futures.workspace = true
+futures-util.workspace = true
 reqwest = { workspace = true, features = ["stream"] }
 rand.workspace = true
 tokio = { workspace = true, features = ["macros", "fs", "process"] }

downloader/src/lib.rs

@@ -15,7 +15,7 @@ use std::{
     time::Duration,
 };
 
-use futures::stream::{self, StreamExt};
+use futures_util::stream::{self, StreamExt};
 use once_cell::sync::Lazy;
 use rand::Rng;
 use regex::Regex;