feat: Allow for skip_state_decode_failures in TychoStreamDecoder to b…

…e set

Took 19 minutes


Took 13 seconds

Took 6 seconds

src/evm/decoder.rs

@@ -84,6 +84,10 @@ impl TychoStreamDecoder {
         guard.tokens = tokens;
     }
 
+    pub fn skip_state_decode_failures(&mut self, skip: bool) {
+        self.skip_state_decode_failures = skip;
+    }
+
     /// Registers a decoder for a given exchange.
     ///
     /// This method maps an exchange identifier to a specific protocol simulation type.

src/evm/stream.rs

@@ -127,6 +127,14 @@ impl ProtocolStreamBuilder {
         self
     }
 
+    /// Skips state decode failures, allowing the stream to continue processing. It raises a warning
+    /// instead of panic.
+    pub fn skip_state_decode_failures(mut self, skip: bool) -> Self {
+        self.decoder
+            .skip_state_decode_failures(skip);
+        self
+    }
+
     pub async fn build(
         self,
     ) -> Result<impl Stream<Item = Result<BlockUpdate, StreamDecodeError>>, StreamError> {