diff --git a/src/rpc.rs b/src/rpc.rs index ce8b3263cf3..4670a5d6617 100644 --- a/src/rpc.rs +++ b/src/rpc.rs @@ -590,15 +590,14 @@ impl Rpc { TransactionStatus::Future | TransactionStatus::Ready | TransactionStatus::Broadcast(_) - | TransactionStatus::Retracted(_) - => continue, + | TransactionStatus::Retracted(_) => continue, TransactionStatus::InBlock(block_hash) => { if self.accept_weak_inclusion { return self .process_block(events_sub, decoder, block_hash, ext_hash) - .await + .await; } - continue + continue; } TransactionStatus::Invalid => return Err("Extrinsic Invalid".into()), TransactionStatus::Usurped(_) => return Err("Extrinsic Usurped".into()), @@ -607,7 +606,7 @@ impl Rpc { // read finalized blocks by default return self .process_block(events_sub, decoder, block_hash, ext_hash) - .await + .await; } TransactionStatus::FinalityTimeout(_) => { return Err("Extrinsic FinalityTimeout".into())