33 lines
997 B
Rust
33 lines
997 B
Rust
use {
|
|
crate::rpc_subscriptions::RpcSubscriptions,
|
|
solana_client::rpc_response::SlotUpdate,
|
|
solana_ledger::blockstore::CompletedSlotsReceiver,
|
|
solana_sdk::timing::timestamp,
|
|
std::{
|
|
sync::Arc,
|
|
thread::{Builder, JoinHandle},
|
|
},
|
|
};
|
|
|
|
pub struct RpcCompletedSlotsService;
|
|
impl RpcCompletedSlotsService {
|
|
pub fn spawn(
|
|
completed_slots_receiver: CompletedSlotsReceiver,
|
|
rpc_subscriptions: Arc<RpcSubscriptions>,
|
|
) -> JoinHandle<()> {
|
|
Builder::new()
|
|
.name("solana-rpc-completed-slots-service".to_string())
|
|
.spawn(move || {
|
|
for slots in completed_slots_receiver.iter() {
|
|
for slot in slots {
|
|
rpc_subscriptions.notify_slot_update(SlotUpdate::Completed {
|
|
slot,
|
|
timestamp: timestamp(),
|
|
});
|
|
}
|
|
}
|
|
})
|
|
.unwrap()
|
|
}
|
|
}
|