Add RowIter::rows_affected

sfackler · sfackler · commit 7d5962ef3ff8 · 2023-03-27T19:24:48.000-04:00
diff --git a/postgres/src/row_iter.rs b/postgres/src/row_iter.rs
@@ -17,6 +17,13 @@ impl<'a> RowIter<'a> {
             it: Box::pin(stream),
         }
     }
+
+    /// Returns the number of rows affected by the query.
+    ///
+    /// This function will return `None` until the iterator has been exhausted.
+    pub fn rows_affected(&self) -> Option<u64> {
+        self.it.rows_affected()
+    }
 }
 
 impl FallibleIterator for RowIter<'_> {

Original file line number	Diff line number	Diff line change
`@@ -17,6 +17,13 @@ impl<'a> RowIter<'a> {`
`17`	`17`	`it: Box::pin(stream),`
`18`	`18`	`}`
`19`	`19`	`}`
	`20`	`+`
	`21`	`+ /// Returns the number of rows affected by the query.`
	`22`	`+ ///`
	`23`	+ /// This function will return `None` until the iterator has been exhausted.
	`24`	`+ pub fn rows_affected(&self) -> Option<u64> {`
	`25`	`+ self.it.rows_affected()`
	`26`	`+ }`
`20`	`27`	`}`
`21`	`28`
`22`	`29`	`impl FallibleIterator for RowIter<'_> {`