diff options
Diffstat (limited to 'src/bayou.rs')
| -rw-r--r-- | src/bayou.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/bayou.rs b/src/bayou.rs index f95bd82..d3027c5 100644 --- a/src/bayou.rs +++ b/src/bayou.rs @@ -443,7 +443,7 @@ impl<S: BayouState> Bayou<S> { struct K2vWatch { pk: String, sk: String, - rx: watch::Receiver<storage::RowRef>, + rx: watch::Receiver<storage::OrphanRowRef>, notify: Notify, } @@ -454,7 +454,7 @@ impl K2vWatch { fn new(creds: &Credentials, pk: String, sk: String) -> Result<Arc<Self>> { let row_client = creds.row_client()?; - let (tx, rx) = watch::channel::<storage::RowRef>(row_client.row(&pk, &sk)); + let (tx, rx) = watch::channel::<storage::OrphanRowRef>(row_client.row(&pk, &sk).to_orphan()); let notify = Notify::new(); let watch = Arc::new(K2vWatch { pk, sk, rx, notify }); @@ -471,7 +471,7 @@ impl K2vWatch { async fn background_task( self_weak: Weak<Self>, k2v: storage::RowStore, - tx: watch::Sender<storage::RowRef>, + tx: watch::Sender<storage::OrphanRowRef>, ) { let mut row = match Weak::upgrade(&self_weak) { Some(this) => k2v.row(&this.pk, &this.sk), @@ -497,7 +497,7 @@ impl K2vWatch { } Ok(new_value) => { row = new_value.to_ref(); - if tx.send(XXX).is_err() { + if tx.send(row.to_orphan()).is_err() { break; } } |