Function deser

indexer/src/util.rs:4–6

(m: &SharedMessage)

use sea_streamer::{Buffer, Message, SharedMessage};

pub fn deser<T: serde::de::DeserializeOwned>(m: &SharedMessage) -> T {
    try_deser(m).expect("Deserialization failed")
}

fn try_deser<T: serde::de::DeserializeOwned>(m: &SharedMessage) -> Result<T, String> {
    m.message().deserialize_json().map_err(|e| {