#[cfg(test)]
mod tests {
    use certstreamrs::CertstreamClient;
    use futures_util::{pin_mut, StreamExt};

    #[tokio::test]
    async fn subscribe_test() {
        let client = CertstreamClient::default();
        let stream = client.watch_certs();
        pin_mut!(stream);

        let msg = stream.next().await;
        assert!(msg.is_some());
    }
}