Unsubscribe when interest in a remote topic goes away

2016-11-21 17:46:45 +13:00 · 2016-11-21 17:46:45 +13:00 · 01d8ba9456
parent 2fa3f13c9b
commit 01d8ba9456
1 changed files with 2 additions and 0 deletions
--- a/racketmq/hub/remote-topic.rkt
+++ b/racketmq/hub/remote-topic.rkt
@ -72,6 +72,8 @@
                                 (hub.topic . ,full-topic)))))
        (established-upstream-hub #f)))

+    (on-stop (unsubscribe!))
+
    (begin/dataflow
      (when (not (equal? (current-upstream-hub) (established-upstream-hub)))
        (unsubscribe!)