Refactor TcpGetNode for improved code organization and readability

oldrev · oldrev · commit c986aaf9389f · 2025-07-19T18:27:18.000+08:00
diff --git a/crates/core/src/runtime/nodes/network_nodes/tcp_get.rs b/crates/core/src/runtime/nodes/network_nodes/tcp_get.rs
@@ -57,6 +57,7 @@ enum TcpClientKind {
 
 #[derive(Debug)]
 #[flow_node("tcp request", red_name = "tcpin")]
+#[allow(dead_code)]
 struct TcpGetNode {
     base: BaseFlowNodeState,
     config: TcpGetNodeConfig,
@@ -288,7 +289,7 @@ impl TcpGetNode {
         }
     }
 
-    async fn read_response(&self, stream: &mut TcpStream, split_count: u32, split_char: u8) -> crate::Result<Vec<u8>> {
+    async fn read_response(&self, stream: &mut TcpStream, _split_count: u32, split_char: u8) -> crate::Result<Vec<u8>> {
         match self.config.mode {
             TcpGetMode::Immediate => self.read_immediate().await,
             TcpGetMode::Time => self.read_time(stream).await,

Original file line number	Diff line number	Diff line change
`@@ -57,6 +57,7 @@ enum TcpClientKind {`
`57`	`57`
`58`	`58`	`#[derive(Debug)]`
`59`	`59`	`#[flow_node("tcp request", red_name = "tcpin")]`
	`60`	`+#[allow(dead_code)]`
`60`	`61`	`struct TcpGetNode {`
`61`	`62`	`base: BaseFlowNodeState,`
`62`	`63`	`config: TcpGetNodeConfig,`
`@@ -288,7 +289,7 @@ impl TcpGetNode {`
`288`	`289`	`}`
`289`	`290`	`}`
`290`	`291`
`291`		`- async fn read_response(&self, stream: &mut TcpStream, split_count: u32, split_char: u8) -> crate::Result<Vec<u8>> {`
	`292`	`+ async fn read_response(&self, stream: &mut TcpStream, _split_count: u32, split_char: u8) -> crate::Result<Vec<u8>> {`
`292`	`293`	`match self.config.mode {`
`293`	`294`	`TcpGetMode::Immediate => self.read_immediate().await,`
`294`	`295`	`TcpGetMode::Time => self.read_time(stream).await,`