diff --git a/yazi-plugin/src/bindings/input.rs b/yazi-plugin/src/bindings/input.rs
index 97413b29..90fccd29 100644
--- a/yazi-plugin/src/bindings/input.rs
+++ b/yazi-plugin/src/bindings/input.rs
@@ -12,12 +12,12 @@ pub struct InputRx<T: StreamExt<Item = Result<String, InputError>>> {
 impl<T: StreamExt<Item = Result<String, InputError>>> InputRx<T> {
 	pub fn new(inner: T) -> Self { Self { inner } }
 
-	pub async fn parse(inner: T) -> (Option<String>, u8) {
+	pub async fn consume(inner: T) -> (Option<String>, u8) {
 		pin!(inner);
-		inner.next().await.map(Self::cast).unwrap_or((None, 0))
+		inner.next().await.map(Self::parse).unwrap_or((None, 0))
 	}
 
-	fn cast(res: Result<String, InputError>) -> (Option<String>, u8) {
+	fn parse(res: Result<String, InputError>) -> (Option<String>, u8) {
 		match res {
 			Ok(s) => (Some(s), 1),
 			Err(InputError::Canceled(s)) => (Some(s), 2),
@@ -31,7 +31,7 @@ impl<T: StreamExt<Item = Result<String, InputError>> + 'static> UserData for Inp
 	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::cast).unwrap_or((None, 0)))
+			Ok(inner.next().await.map(Self::parse).unwrap_or((None, 0)))
 		});
 	}
 }
diff --git a/yazi-plugin/src/utils/layer.rs b/yazi-plugin/src/utils/layer.rs
index 7aee3382..40c49d8a 100644
--- a/yazi-plugin/src/utils/layer.rs
+++ b/yazi-plugin/src/utils/layer.rs
@@ -71,7 +71,7 @@ impl Utils {
 				}));
 
 				if !realtime {
-					return InputRx::parse(rx).await.into_lua_multi(lua);
+					return InputRx::consume(rx).await.into_lua_multi(lua);
 				}
 
 				let debounce = t.raw_get::<_, f64>("debounce").unwrap_or_default();