Update dependencies: oneio 0.21 and bgpkit-broker 0.11

Cargo.toml

@@ -47,7 +47,7 @@ serde = { version = "1.0", features = ["derive"], optional = true }
 bytes = { version = "1.7", optional = true }
 zerocopy = { version = "0.8", features = ["derive"], optional = true }
 hex = { version = "0.4.3", optional = true } # bmp/openbmp parsing
-oneio = { version = "0.20.0", default-features = false, features = ["http", "gz", "bz"], optional = true }
+oneio = { version = "0.21", default-features = false, features = ["http", "gz", "bz"], optional = true }
 regex = { version = "1", optional = true } # used in parser filter
 chrono = { version = "0.4.38", optional = true } # parser filter
 serde_json = { version = "1.0", optional = true } # RIS Live parsing
@@ -123,7 +123,7 @@ harness = false
 [dev-dependencies]
 regex = "1"
 anyhow = "1"
-bgpkit-broker = "0.10.1"
+bgpkit-broker = "0.11"
 env_logger = "0.11"
 kafka = "0.10.0"
 tungstenite = "0.29.0"

benches/data_source.rs

@@ -119,7 +119,7 @@ impl<W: Write> Write for HashingWriter<W> {
 fn download_file<P: AsRef<Path>>(url: &str, target: P) -> io::Result<Digest> {
     let target_path = target.as_ref().to_str().unwrap().to_string();
 
-    oneio::download(url, target_path.as_str(), None).map_err(io::Error::other)?;
+    oneio::download(url, target_path.as_str()).map_err(io::Error::other)?;
 
     let mut reader = get_reader(target_path.as_str()).unwrap();
     let mut writer = HashingWriter {

examples/parse_single_file_parallel.rs

@@ -69,7 +69,7 @@ fn main() {
     let mut downloaded = false;
     if src.starts_with("http://") || src.starts_with("https://") {
         if !local_path.exists() {
-            download(src.as_str(), local_path.to_str().unwrap(), None)
+            download(src.as_str(), local_path.to_str().unwrap())
                 .expect("failed to download source to local file");
             downloaded = true;
         } else {