hexedtech/codemp
3
0
Fork 0
mirror of https://github.com/hexedtech/codemp.git synced 2024-12-23 05:14:54 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

chore: packed clonable handles in sub struct

Browse source
This commit is contained in:
əlemi 2023-11-27 14:55:46 +01:00
parent 15ad6dba55
commit 1265f716d6
1 changed files with 28 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
src/buffer/worker.rs
View file

@ -19,17 +19,21 @@ use super::controller::BufferController;
pub(crate) struct BufferControllerWorker {
uid: String,
name: String,
buffer: Woot,
content: watch::Sender<String>,
operations: mpsc::UnboundedReceiver<TextChange>,
receiver: watch::Receiver<String>,
sender: mpsc::UnboundedSender<TextChange>,
buffer: Woot,
name: String,
stop: mpsc::UnboundedReceiver<()>,
stop_control: mpsc::UnboundedSender<()>,
poller_rx: mpsc::Receiver<oneshot::Sender<()>>,
poller_tx: mpsc::Sender<oneshot::Sender<()>>,
poller: mpsc::Receiver<oneshot::Sender<()>>,
pollers: Vec<oneshot::Sender<()>>,
handles: ClonableHandlesForController,
stop: mpsc::UnboundedReceiver<()>,
}
struct ClonableHandlesForController {
operations: mpsc::UnboundedSender<TextChange>,
poller: mpsc::Sender<oneshot::Sender<()>>,
stop: mpsc::UnboundedSender<()>,
content: watch::Receiver<String>,
}
impl BufferControllerWorker {
@ -42,16 +46,20 @@ impl BufferControllerWorker {
uid.hash(&mut hasher);
let site_id = hasher.finish() as usize;
BufferControllerWorker {
uid, poller_rx, poller_tx,
pollers: Vec::new(),
uid,
name: path.to_string(),
buffer: Woot::new(site_id % (2<<10), ""), // TODO remove the modulo, only for debugging!
content: txt_tx,
operations: op_rx,
receiver: txt_rx,
sender: op_tx,
buffer: Woot::new(site_id % (2<<10), ""), // TODO remove the modulo, only for debugging!
name: path.to_string(),
poller: poller_rx,
pollers: Vec::new(),
handles: ClonableHandlesForController {
operations: op_tx,
poller: poller_tx,
stop: end_tx,
content: txt_rx,
},
stop: end_rx,
stop_control: end_tx,
}
}
@ -78,10 +86,10 @@ impl ControllerWorker<TextChange> for BufferControllerWorker {
fn subscribe(&self) -> BufferController {
BufferController::new(
self.name.clone(),
self.receiver.clone(),
self.sender.clone(),
self.poller_tx.clone(),
self.stop_control.clone(),
self.handles.content.clone(),
self.handles.operations.clone(),
self.handles.poller.clone(),
self.handles.stop.clone(),
)
}
@ -95,7 +103,7 @@ impl ControllerWorker<TextChange> for BufferControllerWorker {
_ = self.stop.recv() => break,
// received a new poller, add it to collection
res = self.poller_rx.recv() => match res {
res = self.poller.recv() => match res {
None => break tracing::error!("poller channel closed"),
Some(tx) => self.pollers.push(tx),
},