pub trait PayloadDecoder<E> { // Required method fn decode(&mut self, bytes: Vec<u8>) -> Result<E, Box<dyn Error>>; }