mroot/yazi
1
0
Fork 0
mirror of https://github.com/sxyazi/yazi.git synced 2026-07-25 08:41:05 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

..

Browse source
This commit is contained in:
sxyazi 2025-01-17 01:16:51 +08:00
parent 7a75f38e8e
commit 7da5350c79
No known key found for this signature in database
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
yazi-plugin/src/utils/sync.rs
View file

@ -43,17 +43,20 @@ impl Utils {
pub(super) fn chan(lua: &Lua) -> mlua::Result<Function> { pub(super) fn chan(lua: &Lua) -> mlua::Result<Function> {
lua.create_function(|lua, (type_, buffer): (mlua::String, Option<usize>)| { lua.create_function(|lua, (type_, buffer): (mlua::String, Option<usize>)| {
match (&*type_.as_bytes(), buffer) { match (&*type_.as_bytes(), buffer) {
(b"mpsc", Some(buffer)) if buffer < 1 => {
Err("Buffer size must be greater than 0".into_lua_err())
}
(b"mpsc", Some(buffer)) => { (b"mpsc", Some(buffer)) => {
let (tx, rx) = tokio::sync::mpsc::channel::<Value>(buffer); let (tx, rx) = tokio::sync::mpsc::channel::<Value>(buffer);
(MpscTx(tx), MpscRx(rx)).into_lua_multi(&lua) (MpscTx(tx), MpscRx(rx)).into_lua_multi(lua)
} }
(b"mpsc", None) => { (b"mpsc", None) => {
let (tx, rx) = tokio::sync::mpsc::unbounded_channel::<Value>(); let (tx, rx) = tokio::sync::mpsc::unbounded_channel::<Value>();
(MpscUnboundedTx(tx), MpscUnboundedRx(rx)).into_lua_multi(&lua) (MpscUnboundedTx(tx), MpscUnboundedRx(rx)).into_lua_multi(lua)
} }
(b"oneshot", _) => { (b"oneshot", _) => {
let (tx, rx) = tokio::sync::oneshot::channel::<Value>(); let (tx, rx) = tokio::sync::oneshot::channel::<Value>();
(OneshotTx(Some(tx)), OneshotRx(Some(rx))).into_lua_multi(&lua) (OneshotTx(Some(tx)), OneshotRx(Some(rx))).into_lua_multi(lua)
} }
_ => Err("Channel type must be `mpsc` or `oneshot`".into_lua_err()), _ => Err("Channel type must be `mpsc` or `oneshot`".into_lua_err()),
} }