Archives
/
xplr
mirror of https://github.com/sayanarijit/xplr
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Optimize optimization hack

Browse Source
pull/416/head
Arijit Basu 3 years ago committed by Arijit Basu
parent 5211e4fa40
commit 7c7351c2e8
2 changed files with 25 additions and 48 deletions
Show Stats Download Patch File Download Diff File

13
src/app.rs
Unescape Escape View File

@ -1452,6 +1452,19 @@ impl App {
self
}
pub fn handle_batch_external_msgs(mut self, msgs: Vec<ExternalMsg>) -> Result<Self> {
for task in msgs
.into_iter()
.map(|msg| Task::new(MsgIn::External(msg), None))
{
self = match task.msg {
MsgIn::Internal(msg) => self.handle_internal(msg)?,
MsgIn::External(msg) => self.handle_external(msg, task.key)?,
};
}
self.refresh()
}
pub fn handle_task(self, task: Task) -> Result<Self> {
let app = match task.msg {
MsgIn::Internal(msg) => self.handle_internal(msg)?,

60
src/runner.rs
Unescape Escape View File

@ -457,14 +457,8 @@ impl Runner {
CallLuaSilently(func) => {
match call_lua(&app, &lua, &func, false) {
Ok(Some(msgs)) => {
for msg in msgs {
app = app.handle_task(
app::Task::new(
app::MsgIn::External(msg),
None,
),
)?;
}
app = app
.handle_batch_external_msgs(msgs)?;
}
Ok(None) => {}
Err(err) => {
@ -490,14 +484,8 @@ impl Runner {
match pipe_reader::read_all(&app.pipe.msg_in) {
Ok(msgs) => {
for msg in msgs {
app = app.handle_task(
app::Task::new(
app::MsgIn::External(msg),
None,
),
)?;
}
app = app
.handle_batch_external_msgs(msgs)?;
}
Err(err) => {
app = app.log_error(err.to_string())?;
@ -527,14 +515,8 @@ impl Runner {
match call_lua(&app, &lua, &func, false) {
Ok(Some(msgs)) => {
for msg in msgs {
app = app.handle_task(
app::Task::new(
app::MsgIn::External(msg),
None,
),
)?;
}
app = app
.handle_batch_external_msgs(msgs)?;
}
Ok(None) => {}
Err(err) => {
@ -585,14 +567,8 @@ impl Runner {
match res {
Ok(Some(msgs)) => {
for msg in msgs {
app = app.handle_task(
app::Task::new(
app::MsgIn::External(msg),
None,
),
)?;
}
app = app
.handle_batch_external_msgs(msgs)?;
}
Ok(None) => {}
Err(err) => {
@ -630,14 +606,8 @@ impl Runner {
match res {
Ok(Some(msgs)) => {
for msg in msgs {
app = app.handle_task(
app::Task::new(
app::MsgIn::External(msg),
None,
),
)?;
}
app = app
.handle_batch_external_msgs(msgs)?;
}
Ok(None) => {}
Err(err) => {
@ -677,14 +647,8 @@ impl Runner {
// TODO remove duplicate segment
match pipe_reader::read_all(&app.pipe.msg_in) {
Ok(msgs) => {
for msg in msgs {
app = app.handle_task(
app::Task::new(
app::MsgIn::External(msg),
None,
),
)?;
}
app = app
.handle_batch_external_msgs(msgs)?;
}
Err(err) => {
app = app.log_error(err.to_string())?;

Write Preview
Loading…
Cancel
Save