update input and output

Author: luoluoyuyu

src/runtime/input/input_runner.rs

@@ -13,7 +13,7 @@
 use crate::runtime::buffer_and_event::BufferOrEvent;
 use crate::runtime::common::TaskCompletionFlag;
 use crate::runtime::input::input_protocol::InputProtocol;
-use crate::runtime::input::input::{Input, InputState};
+use crate::runtime::input::{Input, InputState};
 use crate::runtime::processor::function_error::FunctionErrorReport;
 use crate::runtime::task::ControlMailBox;
 use crossbeam_channel::{Receiver, Sender, bounded, unbounded};

src/runtime/input/input.rs src/runtime/input/interface.rssrc/runtime/input/input.rs renamed to src/runtime/input/interface.rs

@@ -11,11 +11,11 @@
 // limitations under the License.
 
 mod input_protocol;
-mod input;
+mod interface;
 mod input_provider;
 mod input_runner;
 pub mod protocol;
 
-pub use input::{Input, InputState};
+pub use interface::{Input, InputState};
 pub use input_provider::InputProvider;
 pub use input_runner::InputRunner;

src/runtime/input/mod.rs

@@ -11,12 +11,14 @@
 // limitations under the License.
 
 mod output_protocol;
-mod output;
+mod interface;
 mod output_provider;
 mod output_runner;
 mod protocol;
 
+#[allow(unused_imports)]
 pub use output_protocol::OutputProtocol;
-pub use output::Output;
+pub use interface::Output;
 pub use output_provider::OutputProvider;
+#[allow(unused_imports)]
 pub use output_runner::OutputRunner;

src/runtime/output/output.rs src/runtime/output/interface.rssrc/runtime/output/output.rs renamed to src/runtime/output/interface.rs

@@ -259,6 +259,7 @@ impl WasmTask {
         Ok(())
     }
 
+    #[allow(clippy::too_many_arguments)]
     fn task_thread_loop(
         task_name: String,
         mut inputs: Vec<Box<dyn Input>>,
@@ -369,6 +370,7 @@ impl WasmTask {
         log::info!("Task thread exiting: {}", task_name);
     }
 
+    #[allow(clippy::too_many_arguments)]
     fn handle_control_signal(
         signal: TaskControlSignal,
         state: &mut TaskState,