syndicate-lang
/
racketmq-2017
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Minor refactoring

This commit is contained in:
Tony Garnock-Jones 2016-11-21 17:05:01 +13:00
parent 165a35a471
commit f6cb3282bd
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
racketmq/hub/remote-topic.rkt
View File

@ -14,6 +14,13 @@
(require "../private/util.rkt")
(require "../protocol.rkt")
(define (set-minimum xs)
(for/fold [(i #f)] [(candidate (in-set xs))]
(cond [(not candidate) i]
[(not i) candidate]
[(< candidate i) candidate]
[else i])))
(define (remote-topic-main full-topic)
(define sub-id (random-hex-string 16))
(log-info "Remote sub endpoint ~a" sub-id)
@ -29,10 +36,7 @@
(define/query-set poll-intervals (topic-demand full-topic $i) i)
(define/query-config min-poll-interval 60)
(begin/dataflow
(define candidate (for/fold [(i #f)] [(candidate (in-set (poll-intervals)))]
(cond [(not i) candidate]
[(< candidate i) candidate]
[else i])))
(define candidate (set-minimum (poll-intervals)))
(poll-interval-seconds (and candidate (max candidate (min-poll-interval)))))
(begin/dataflow
(log-info "Poll interval for ~a is now ~a"