diff --git a/src/runtime/communication.rs b/src/runtime/communication.rs index c7b00ba871ead94626a13b65778b09e2d077e121..fbc0f14ad660eaa7757fb1eaff39e4407c631f36 100644 --- a/src/runtime/communication.rs +++ b/src/runtime/communication.rs @@ -1416,6 +1416,10 @@ impl SyncProtoContext<'_> { self.predicate.query(var).map(SpecVal::is_firing) } + pub(crate) fn did_put_or_get(&mut self, port: PortId) -> bool { + self.branch_inner.did_put_or_get.contains(&port) + } + // The component calls the runtime back, trying to inspect a port's message pub(crate) fn read_msg(&mut self, port: PortId) -> Option<&Payload> { let maybe_msg = self.branch_inner.inbox.get(&port);