skystreamer 0.2.2

Idiomatic Rust library for the AT Firehose streaming API
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

// use color_eyre::Result;
use futures::{pin_mut, StreamExt};
use skystreamer::{stream::EventStream, RepoSubscription};

#[tokio::main]
pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create subscription to bsky.network
    let subscription = RepoSubscription::new("bsky.network").await.unwrap();
    // let subscription = repo;

    let mut binding = EventStream::new(subscription);
    let event_stream = binding.stream().await?;

    // let commit_stream = subscription.stream_commits().await;
    pin_mut!(event_stream);

    while let Some(record) = event_stream.next().await {
        // stream unknown record types
        if let skystreamer::types::commit::Record::Other(val) = record {
            println!("{:?}", val);
        }
    }

    Ok(())
}