+1 -1

ufos/src/consumer.rs

Reviewed

··· 1 1 - use jetstream::exports::Did; 2 1 use jetstream::{ 3 2 events::{ 4 3 account::AccountEvent, 5 4 commit::{CommitData, CommitEvent, CommitInfo}, 6 5 Cursor, EventInfo, JetstreamEvent, 7 6 }, 7 7 + exports::Did, 8 8 DefaultJetstreamEndpoints, JetstreamCompression, JetstreamConfig, JetstreamConnector, 9 9 JetstreamReceiver, 10 10 };

+1 -2

ufos/src/main.rs

Reviewed

··· 1 1 use clap::Parser; 2 2 use std::path::PathBuf; 3 3 - use ufos::consumer; 4 4 - use ufos::store; 3 3 + use ufos::{consumer, store}; 5 4 6 5 /// Aggregate links in the at-mosphere 7 6 #[derive(Parser, Debug)]

+1 -2

ufos/src/store.rs

Reviewed

··· 1 1 use crate::EventBatch; 2 2 use std::time::Duration; 3 3 - use tokio::sync::mpsc::Receiver; 4 4 - use tokio::time::sleep; 3 3 + use tokio::{sync::mpsc::Receiver, time::sleep}; 5 4 6 5 pub async fn receive(mut receiver: Receiver<EventBatch>) -> anyhow::Result<()> { 7 6 loop {