如何实现轮询异步fn的Future或Stream？

async fn polling_async_fn(future: &mut FutureType) {
    loop {
        match future.poll() {
            Poll::Ready(result) => {
                // Future已经完成，可以处理结果
                println!("Future result: {:?}", result);
                break;
            }
            Poll::Pending => {
                // Future尚未完成，挂起函数执行并等待下一次轮询
                tokio::time::sleep(Duration::from_secs(1)).await;
            }
        }
    }
}

async fn polling_async_stream(stream: &mut StreamType) {
    loop {
        match stream.next().await {
            Some(item) => {
                // 处理Stream的下一个元素
                println!("Stream item: {:?}", item);
            }
            None => {
                // Stream已经结束
                break;
            }
        }
        tokio::time::sleep(Duration::from_secs(1)).await;
    }
}