Function consume 

async fn consume<E>(rx: &mut Receiver<E>) -> Result<(), Error>
where
    E: IsEvent,