Skip to content

Commit d97d418

Browse files
committed
don't call removeWatchForEvents again when the matcher returns EVENT_TIMEOUT, it will be cleaned up further down in handle() in timeout handling
1 parent b9639d5 commit d97d418

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/CorrelationEngine.php

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -184,10 +184,9 @@ public function handle(Event $event) : void
184184
$this->incrStat('handled', (string)$event->event . "|" . get_class($matcher));
185185
}
186186

187-
// If we are timed out then remove any future event watching and flag the matcher for timeout processing.
187+
// If we are timed out then flag the matcher for timeout processing.
188188
if ($this->isFlagSet($result, $matcher::EVENT_TIMEOUT)) {
189189
$timedOutMatchers[] = $matcher;
190-
$this->removeWatchForEvents($matcher, $expecting);
191190
}
192191

193192
//Matcher has told us to suppress further processing of this event.

0 commit comments

Comments
 (0)