lune-org/lune
1
1
Fork 0
mirror of https://github.com/lune-org/lune.git synced 2024-12-12 13:00:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Use blocking io for print and warn globals

Browse source
This commit is contained in:
Filip Tibell 2024-01-14 09:38:56 +01:00
parent 6f8b1e4896
commit 9c27057bf3
No known key found for this signature in database
2 changed files with 10 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/lune/globals/print.rs
View file

@ -1,23 +1,15 @@
use std::io::Write as _;
use mlua::prelude::*; use mlua::prelude::*;
use tokio::{
io::{self, AsyncWriteExt},
task,
};
use crate::lune::util::formatting::pretty_format_multi_value; use crate::lune::util::formatting::pretty_format_multi_value;
pub fn create(lua: &Lua) -> LuaResult<impl IntoLua<'_>> { pub fn create(lua: &Lua) -> LuaResult<impl IntoLua<'_>> {
lua.create_function(|_, args: LuaMultiValue| { lua.create_function(|_, args: LuaMultiValue| {
let formatted = format!("{}\n", pretty_format_multi_value(&args)?); let formatted = format!("{}\n", pretty_format_multi_value(&args)?);
task::spawn(async move { let mut stdout = std::io::stdout();
let _res = async move { stdout.write_all(formatted.as_bytes())?;
let mut stdout = io::stdout(); stdout.flush()?;
stdout.write_all(formatted.as_bytes()).await?;
stdout.flush().await?;
Ok::<_, LuaError>(())
};
// FUTURE: Send any error back to scheduler and emit it properly
});
Ok(()) Ok(())
}) })
} }

18
src/lune/globals/warn.rs
View file

@ -1,8 +1,6 @@
use std::io::Write as _;
use mlua::prelude::*; use mlua::prelude::*;
use tokio::{
io::{self, AsyncWriteExt},
task,
};
use crate::lune::util::formatting::{format_label, pretty_format_multi_value}; use crate::lune::util::formatting::{format_label, pretty_format_multi_value};
@ -13,15 +11,9 @@ pub fn create(lua: &Lua) -> LuaResult<impl IntoLua<'_>> {
format_label("warn"), format_label("warn"),
pretty_format_multi_value(&args)? pretty_format_multi_value(&args)?
); );
task::spawn(async move { let mut stderr = std::io::stderr();
let _res = async move { stderr.write_all(formatted.as_bytes())?;
let mut stdout = io::stderr(); stderr.flush()?;
stdout.write_all(formatted.as_bytes()).await?;
stdout.flush().await?;
Ok::<_, LuaError>(())
};
// FUTURE: Send any error back to scheduler and emit it properly
});
Ok(()) Ok(())
}) })
} }