diff --git a/src/runtime2/component/component_pdl.rs b/src/runtime2/component/component_pdl.rs index c125b9dbe01c19ce69428411d420711a9c634d0d..afa053bf3d65d24b3d13b14d3c8fcbc5921973cf 100644 --- a/src/runtime2/component/component_pdl.rs +++ b/src/runtime2/component/component_pdl.rs @@ -371,7 +371,7 @@ impl Component for CompPDL { // the synchronous round is satisfied. let port_info = comp_ctx.get_port_mut(port_handle); port_info.last_instruction = PortInstruction::SourceLocation(expr_id); - let port_is_closed = port_info.state == PortState::Closed; + let port_is_closed = port_info.state.is_closed(); // Register port as part of select guard if let Err(_err) = self.select_state.register_select_case_port(comp_ctx, case_index, port_index, port_id) { @@ -614,7 +614,7 @@ impl CompPDL { created_id: created_port_id, }; - if creator_port.state == PortState::Closed { + if creator_port.state.is_closed() { closed_port_id_pairs.push(port_id_pair) } else { opened_port_id_pairs.push(port_id_pair);