solana-streamer-sdk 1.5.13

A low-latency Solana DEX event streaming facade over sol-parser-sdk with Yellowstone gRPC, ShredStream, and RPC parsing helpers.
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
40
41
42
43
44
45
46
47
48
49
50

use tokio::task::JoinHandle;

/// Subscription handle for managing and stopping subscriptions
pub struct SubscriptionHandle {
    stream_handle: Option<JoinHandle<()>>,
    event_handle: Option<JoinHandle<()>>,
    metrics_handle: Option<JoinHandle<()>>,
}

impl SubscriptionHandle {
    /// Create a new subscription handle
    pub fn new(
        stream_handle: JoinHandle<()>,
        event_handle: Option<JoinHandle<()>>,
        metrics_handle: Option<JoinHandle<()>>,
    ) -> Self {
        Self { stream_handle: Some(stream_handle), event_handle, metrics_handle }
    }

    pub fn metrics_only(metrics_handle: Option<JoinHandle<()>>) -> Self {
        Self { stream_handle: None, event_handle: None, metrics_handle }
    }

    /// Stop subscription and abort all related tasks
    pub fn stop(self) {
        if let Some(handle) = self.stream_handle {
            handle.abort();
        }
        if let Some(handle) = self.event_handle {
            handle.abort();
        }
        if let Some(handle) = self.metrics_handle {
            handle.abort();
        }
    }

    /// Asynchronously wait for all tasks to complete
    pub async fn join(self) -> Result<(), tokio::task::JoinError> {
        if let Some(handle) = self.stream_handle {
            let _ = handle.await;
        }
        if let Some(handle) = self.event_handle {
            let _ = handle.await;
        }
        if let Some(handle) = self.metrics_handle {
            let _ = handle.await;
        }
        Ok(())
    }
}