Files
zap-stream-app/src/sub.rs
2025-01-09 14:26:47 +00:00

22 lines
438 B
Rust

use log::info;
use nostrdb::{Ndb, Subscription};
pub struct SubRef {
pub sub: Subscription,
ndb: Ndb,
}
impl SubRef {
pub fn new(sub: Subscription, ndb: Ndb) -> Self {
info!("Creating sub: {}", sub.id());
SubRef { sub, ndb }
}
}
impl Drop for SubRef {
fn drop(&mut self) {
self.ndb.unsubscribe(self.sub).expect("unsubscribe failed");
info!("Closing sub: {}", self.sub.id());
}
}