pyth-lazer-client 21.0.0

A Rust client for Pyth Lazer
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use {
    anyhow::Context as _,
    arc_swap::ArcSwap,
    futures::Stream,
    futures_util::StreamExt as _,
    std::sync::Arc,
    tracing::{Instrument as _, info},
};

#[async_trait::async_trait]
pub trait StreamIntoAutoUpdatedHandle: Stream + Unpin + Sized + 'static
where
    Self::Item: Send + Sync,
{
    /// Create an `ArcSwap` that provides access to the most recent value produced by the stream.
    async fn into_auto_updated_handle(mut self) -> anyhow::Result<Arc<ArcSwap<Self::Item>>> {
        let first_value = self
            .next()
            .await
            .context("cannot create auto updated handle from empty stream")?;
        let handle = Arc::new(ArcSwap::new(Arc::new(first_value)));
        let weak_handle = Arc::downgrade(&handle);
        tokio::spawn(
            async move {
                while let Some(value) = self.next().await {
                    let Some(handle) = weak_handle.upgrade() else {
                        info!("handle dropped, stopping auto handle update task");
                        return;
                    };
                    handle.store(Arc::new(value));
                }
            }
            .in_current_span(),
        );
        Ok(handle)
    }
}

impl<T: Stream + Unpin + 'static> StreamIntoAutoUpdatedHandle for T where T::Item: Send + Sync {}