pub trait Subscription { // Required method fn next( &mut self, timeout: Option<Duration>, ) -> Result<Option<Entry>, Error>; }