/// no more events from this source, or there's an error.
pub fn event(&mut self) -> Result<Vec<BrokerEvent>, NodeEventError> {
loop {
info!("getting next event from local node");
debug!("getting next event from local node");
if let Some(event) = self.events.next() {
info!("got event from local node");
match event {