chore: Remove unused IPC async (#19223)

pola-rs · Oct 14, 2024 · 44cf3ad · 44cf3ad
1 parent 1536bb0
commit 44cf3ad
Show file tree

Hide file tree

Showing 12 changed files with 4 additions and 1,115 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/polars-arrow/Cargo.toml b/crates/polars-arrow/Cargo.toml
@@ -55,9 +55,6 @@ zstd = { workspace = true, optional = true }
 # to write to parquet as a stream
 futures = { workspace = true, optional = true }
 
-# to read IPC as a stream
-async-stream = { version = "0.3.2", optional = true }
-
 # avro support
 avro-schema = { workspace = true, optional = true }
 
@@ -75,6 +72,7 @@ arrow-array = { workspace = true, optional = true }
 arrow-buffer = { workspace = true, optional = true }
 arrow-data = { workspace = true, optional = true }
 arrow-schema = { workspace = true, optional = true }
+tokio = { workspace = true, optional = true }
 
 [dev-dependencies]
 criterion = "0.5"
@@ -105,8 +103,6 @@ full = [
   "arrow_rs",
   "io_ipc",
   "io_flight",
-  "io_ipc_write_async",
-  "io_ipc_read_async",
   "io_ipc_compression",
   "io_avro",
   "io_avro_compression",
@@ -119,8 +115,6 @@ full = [
 ]
 arrow_rs = ["arrow-buffer", "arrow-schema", "arrow-data", "arrow-array"]
 io_ipc = ["arrow-format", "polars-error/arrow-format"]
-io_ipc_write_async = ["io_ipc", "futures"]
-io_ipc_read_async = ["io_ipc", "futures", "async-stream"]
 io_ipc_compression = ["lz4", "zstd", "io_ipc"]
 io_flight = ["io_ipc", "arrow-format/flight-data"]
 

diff --git a/crates/polars-arrow/src/io/ipc/read/file_async.rs b/crates/polars-arrow/src/io/ipc/read/file_async.rs