From de814bfc49d3952ab63085df5dbd351620ca77dc Mon Sep 17 00:00:00 2001 From: sxyazi Date: Wed, 19 Jun 2024 17:26:46 +0800 Subject: [PATCH] Remove unused file --- yazi-plugin/src/bindings/confirm.rs | 37 ----------------------------- 1 file changed, 37 deletions(-) delete mode 100644 yazi-plugin/src/bindings/confirm.rs diff --git a/yazi-plugin/src/bindings/confirm.rs b/yazi-plugin/src/bindings/confirm.rs deleted file mode 100644 index 87a46700..00000000 --- a/yazi-plugin/src/bindings/confirm.rs +++ /dev/null @@ -1,37 +0,0 @@ -use std::pin::Pin; - -use mlua::{prelude::LuaUserDataMethods, UserData}; -use tokio::pin; -use tokio_stream::StreamExt; -use yazi_shared::InputError; - -pub struct ConfirmRx>> { - inner: T, -} - -impl>> InputRx { - pub fn new(inner: T) -> Self { Self { inner } } - - pub async fn consume(inner: T) -> (Option, u8) { - pin!(inner); - inner.next().await.map(Self::parse).unwrap_or((None, 0)) - } - - fn parse(res: Result) -> (Option, u8) { - match res { - Ok(s) => (Some(s), 1), - Err(InputError::Canceled(s)) => (Some(s), 2), - Err(InputError::Typed(s)) => (Some(s), 3), - _ => (None, 0), - } - } -} - -impl> + 'static> UserData for InputRx { - fn add_methods<'lua, M: LuaUserDataMethods<'lua, Self>>(methods: &mut M) { - methods.add_async_method_mut("recv", |_, me, ()| async move { - let mut inner = unsafe { Pin::new_unchecked(&mut me.inner) }; - Ok(inner.next().await.map(Self::parse).unwrap_or((None, 0))) - }); - } -}