diff --git a/src/runtime2/component/component_internet.rs b/src/runtime2/component/component_internet.rs index e9e41ac593a5b19ee65ba52fb9d25647a1a9fe4c..7e3ba9ca5512298f3a6bdbf2c7277889fb4cabec 100644 --- a/src/runtime2/component/component_internet.rs +++ b/src/runtime2/component/component_internet.rs @@ -207,6 +207,8 @@ impl Component for ComponentTcpClient { return CompScheduling::Sleep; } } else { + let port_handle = comp_ctx.get_port_handle(self.pdl_input_port_id); + comp_ctx.get_port_mut(port_handle).last_instruction = PortInstruction::NoSource; self.exec_state.set_as_blocked_get(self.pdl_input_port_id); return CompScheduling::Sleep; }