pub async fn wait_for_events(agent: &mut Agent) -> Vec<Event>
Wait for new events, or Error::Disconnected when stream is closed and will not reconnect.