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

Small sleep time could be a temp fix for now

Browse source
This commit is contained in:
frelodev 2024-02-14 15:38:06 +01:00
parent 5df3234e0b
commit a785321287
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/rust/buffer.rs
View file

@ -63,11 +63,12 @@ impl JsBufferController {
)?; )?;
let _controller = self.0.clone(); let _controller = self.0.clone();
tokio::spawn(async move { tokio::spawn(async move {
tokio::time::sleep(std::time::Duration::from_millis(200)).await; //tokio::time::sleep(std::time::Duration::from_secs(1)).await;
loop { loop {
tokio::time::sleep(std::time::Duration::from_millis(200)).await;
match _controller.recv().await { match _controller.recv().await {
Ok(event) => { Ok(event) => {
tsfn.call(event.clone(), ThreadsafeFunctionCallMode::NonBlocking); //check this shit with tracing also we could use Ok(event) to get the error tsfn.call(event, ThreadsafeFunctionCallMode::NonBlocking); //check this shit with tracing also we could use Ok(event) to get the error
}, },
Err(codemp::Error::Deadlocked) => continue, Err(codemp::Error::Deadlocked) => continue,
Err(e) => break tracing::warn!("error receiving: {}", e), Err(e) => break tracing::warn!("error receiving: {}", e),
@ -83,8 +84,10 @@ impl JsBufferController {
self.0.content() self.0.content()
} }
#[napi]
pub fn get_name(&self) -> String {
self.0.name().to_string()
}
#[napi] #[napi]
pub async fn recv(&self) -> napi::Result<JsTextChange> { pub async fn recv(&self) -> napi::Result<JsTextChange> {