Merge pull request from hexedtech/fix/dt-send-patch

fix: send only delta patches via DiamondTypes
This commit is contained in:
zaaarf 2025-01-13 12:44:28 +01:00 committed by GitHub
commit b8b19f8f9a
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -1,6 +1,6 @@
use std::sync::Arc;
use diamond_types::list::encoding::EncodeOptions;
use diamond_types::list::encoding::ENCODE_PATCH;
use diamond_types::list::{Branch, OpLog};
use diamond_types::LocalVersion;
use tokio::sync::{mpsc, oneshot, watch};
@ -192,7 +192,7 @@ impl BufferWorker {
if change.is_delete() || change.is_insert() {
tx.send(Operation {
data: self.oplog.encode_from(EncodeOptions::default(), &last_ver),
data: self.oplog.encode_from(ENCODE_PATCH, &last_ver),
})
.await
.unwrap_or_warn("failed to send change!");