build: fallible-iterator

aljazerzen · Mar 26, 2024 · cfd908e · cfd908e
1 parent 74fdea8
commit cfd908e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/connector_arrow/Cargo.toml b/connector_arrow/Cargo.toml
@@ -26,7 +26,6 @@ arrow = { version = "49", default-features = false }
 # common optional
 hex = { version = "0.4", optional = true }
 fallible-streaming-iterator = { version = "0.1", optional = true }
-fallible-iterator = { version = "0.2", optional = true }
 csv = { version = "1", optional = true }
 bytes = { version = "1", optional = true }
 byteorder = { version = "1", optional = true }
@@ -48,6 +47,11 @@ version = "0.6.6"
 default-features = false
 optional = true
 
+[dependencies.postgres-fallible-iterator]
+package = "fallible-iterator"
+version = "0.2" # this dep is bound to potgres's transitive dep
+optional = true
+
 [dependencies.rusqlite]
 version = "0.31.0"
 default-features = false
@@ -85,11 +89,11 @@ all = ["src_sqlite", "src_duckdb", "src_postgres", "src_mysql", "src_tiberius"]
 src_postgres = [
     "postgres",
     "postgres-protocol",
+    "postgres-fallible-iterator",
     "csv",
     "hex",
     "bytes",
     "byteorder",
-    "fallible-iterator",
 ]
 src_sqlite = ["rusqlite"]
 src_duckdb = ["duckdb", "fallible-streaming-iterator"]

diff --git a/connector_arrow/src/postgres/protocol_extended.rs b/connector_arrow/src/postgres/protocol_extended.rs
@@ -65,7 +65,7 @@ impl<'a> Iterator for PostgresBatchStream<'a> {
 }
 
 struct PostgresRowStream<'a> {
-    iter: fallible_iterator::Fuse<postgres::RowIter<'a>>,
+    iter: postgres_fallible_iterator::Fuse<postgres::RowIter<'a>>,
 }
 
 impl<'a> PostgresRowStream<'a> {