Method decode_logs

src/decode.rs:41–51

(&self, logs: Vec<Log>, py: Python<'py>)

    }

    pub fn decode_logs<'py>(&self, logs: Vec<Log>, py: Python<'py>) -> PyResult<Bound<'py, PyAny>> {
        let decoder = self.clone();

        future_into_py(py, async move {
            Ok(tokio::task::spawn_blocking(move || {
                Python::attach(|py| decoder.decode_logs_sync(logs, py))
            })
            .await
            .unwrap())
        })
    }

    pub fn decode_logs_sync(&self, logs: Vec<Log>, py: Python) -> Vec<Option<DecodedEvent>> {
        logs.iter()