hexedtech/codemp
3
0
Fork 0
mirror of https://github.com/hexedtech/codemp.git synced 2024-11-22 15:24:48 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

chore: commented out unused stuff for now

Browse source
This commit is contained in:
əlemi 2023-04-13 00:54:37 +02:00
parent 07b8e3a517
commit 56db49746d
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/server/buffer/actor.rs
View file

@ -1,7 +1,7 @@
use codemp::proto::{RawOp, OperationRequest}; use codemp::proto::{RawOp, OperationRequest};
use tokio::sync::{mpsc, broadcast, watch}; use tokio::sync::{mpsc, broadcast, watch};
use tracing::{error, warn}; use tracing::{error, warn};
use md5::Digest; // use md5::Digest;
use operational_transform::OperationSeq; use operational_transform::OperationSeq;
@ -19,7 +19,7 @@ pub trait BufferStore<T> {
pub struct BufferHandle { pub struct BufferHandle {
pub edit: mpsc::Sender<OperationRequest>, pub edit: mpsc::Sender<OperationRequest>,
events: broadcast::Sender<RawOp>, events: broadcast::Sender<RawOp>,
pub digest: watch::Receiver<Digest>, // pub digest: watch::Receiver<Digest>,
pub content: watch::Receiver<String>, pub content: watch::Receiver<String>,
} }
@ -28,7 +28,7 @@ impl BufferHandle {
let init_val = init.unwrap_or("".into()); let init_val = init.unwrap_or("".into());
let (edits_tx, edits_rx) = mpsc::channel(64); // TODO hardcoded size let (edits_tx, edits_rx) = mpsc::channel(64); // TODO hardcoded size
let (events_tx, _events_rx) = broadcast::channel(64); // TODO hardcoded size let (events_tx, _events_rx) = broadcast::channel(64); // TODO hardcoded size
let (digest_tx, digest_rx) = watch::channel(md5::compute(&init_val)); // let (digest_tx, digest_rx) = watch::channel(md5::compute(&init_val));
let (content_tx, content_rx) = watch::channel(init_val.clone()); let (content_tx, content_rx) = watch::channel(init_val.clone());
let events_tx_clone = events_tx.clone(); let events_tx_clone = events_tx.clone();
@ -38,7 +38,7 @@ impl BufferHandle {
store: init_val, store: init_val,
edits: edits_rx, edits: edits_rx,
events: events_tx_clone, events: events_tx_clone,
digest: digest_tx, // digest: digest_tx,
content: content_tx, content: content_tx,
}; };
worker.work().await worker.work().await
@ -47,7 +47,7 @@ impl BufferHandle {
BufferHandle { BufferHandle {
edit: edits_tx, edit: edits_tx,
events: events_tx, events: events_tx,
digest: digest_rx, // digest: digest_rx,
content: content_rx, content: content_rx,
} }
} }
@ -61,7 +61,7 @@ struct BufferWorker {
store: String, store: String,
edits: mpsc::Receiver<OperationRequest>, edits: mpsc::Receiver<OperationRequest>,
events: broadcast::Sender<RawOp>, events: broadcast::Sender<RawOp>,
digest: watch::Sender<Digest>, // digest: watch::Sender<Digest>,
content: watch::Sender<String>, content: watch::Sender<String>,
} }