Only try to sync on evt? subscriptions

This commit is contained in:
Tony Garnock-Jones 2012-03-24 16:12:18 -04:00
parent 4e8c0b4612
commit bdaee80ce8
1 changed files with 3 additions and 1 deletions

View File

@ -361,7 +361,9 @@
(error 'ground-vm "No meta-actions available in ground-vm: ~v" actions))
(define waiting? (quasi-queue-empty? (vm-pending-actions state)))
(define active-events (for/list ([(eid e) (in-hash (vm-endpoints state))]
#:when (eq? (topic-role (endpoint-topic e)) 'subscriber))
#:when (and (evt? (topic-pattern (endpoint-topic e)))
(eq? (topic-role (endpoint-topic e))
'subscriber)))
(define evt (topic-pattern (endpoint-topic e)))
(wrap-evt evt (lambda (message)
(lambda (state)