diff --git a/src/runtime2/component/component_context.rs b/src/runtime2/component/component_context.rs index 4ee51581b3f46d0b8c43f278b58a8b3fc7e391cb..1d00c2c83fa9b0ae269fe690f659ef94cf4c9e1d 100644 --- a/src/runtime2/component/component_context.rs +++ b/src/runtime2/component/component_context.rs @@ -79,6 +79,11 @@ impl PortState { self.is_set(PortStateFlag::BlockedDueToFullBuffers); } + #[inline] + pub fn is_blocked_due_to_port_change(&self) -> bool { + return self.is_set(PortStateFlag::BlockedDueToPeerChange); + } + // lower-level utils #[inline] pub fn set(&mut self, flag: PortStateFlag) {