Convert a vector of rows to a RowIter (pinned boxed stream)
(rows: Vec<(Key, DataRow)>)
| 510 | |
| 511 | /// Convert a vector of rows to a RowIter (pinned boxed stream) |
| 512 | fn rows_to_iter(rows: Vec<(Key, DataRow)>) -> RowIter<'static> { |
| 513 | let stream = stream::iter(rows.into_iter().map(Ok)); |
| 514 | Box::pin(stream) |
| 515 | } |
| 516 | |
| 517 | // Implement the Store trait |
| 518 | #[async_trait] |