Updated to latest version of substreams-rs with correct ordering of deltas

Author: maoueh

Cargo.lock

@@ -8,7 +8,7 @@ use substreams_database_change::tables::Tables;
 pub fn add_block_meta_to_tables(tables: &mut Tables, deltas: Deltas<DeltaProto<BlockMeta>>) {
     use substreams::pb::substreams::store_delta::Operation;
 
-    for delta in deltas {
+    for delta in deltas.into_iter() {
         match delta.operation {
             Operation::Create => push_create(
                 tables,

src/db_out.rs

@@ -6,7 +6,7 @@ use crate::{block_timestamp::BlockTimestamp, pb::eth::block_meta::v1::BlockMeta}
 pub fn add_block_meta_to_tables(tables: &mut Tables, deltas: Deltas<DeltaProto<BlockMeta>>) {
     use substreams::pb::substreams::store_delta::Operation;
 
-    for delta in deltas {
+    for delta in deltas.into_iter() {
         match delta.operation {
             Operation::Create => push_create(
                 tables,

src/graph_out.rs

@@ -7,7 +7,7 @@ use crate::pb::eth::block_meta::v1::BlockMeta;
 pub fn block_meta_to_kv_ops(ops: &mut KvOperations, deltas: Deltas<DeltaProto<BlockMeta>>) {
     use substreams::pb::substreams::store_delta::Operation;
 
-    for delta in deltas {
+    for delta in deltas.into_iter() {
         match delta.operation {
             Operation::Create | Operation::Update => {
                 let val = proto::encode(&delta.new_value).unwrap();