fix initialization error
This commit is contained in:
parent
62466ddf9e
commit
df3a082d1e
|
@ -412,20 +412,6 @@
|
||||||
(current-inexact-milliseconds))
|
(current-inexact-milliseconds))
|
||||||
empty)]
|
empty)]
|
||||||
[head last]
|
[head last]
|
||||||
[producer (proc->signal
|
|
||||||
(lambda ()
|
|
||||||
(let* ([now (and (signal? consumer) (current-inexact-milliseconds))]
|
|
||||||
[ms (value-now ms-b)])
|
|
||||||
(let loop ()
|
|
||||||
(if (or (empty? (mcdr head))
|
|
||||||
(< now (+ ms (cdr (mcar (mcdr head))))))
|
|
||||||
(let ([val (car (mcar head))])
|
|
||||||
(if (event-set? val)
|
|
||||||
(make-events-now (event-set-events val))
|
|
||||||
val))
|
|
||||||
(begin
|
|
||||||
(set! head (mcdr head))
|
|
||||||
(loop)))))))]
|
|
||||||
[consumer (proc->signal
|
[consumer (proc->signal
|
||||||
(lambda ()
|
(lambda ()
|
||||||
(let* ([now (current-inexact-milliseconds)]
|
(let* ([now (current-inexact-milliseconds)]
|
||||||
|
@ -436,7 +422,21 @@
|
||||||
empty))
|
empty))
|
||||||
(set! last (mcdr last))
|
(set! last (mcdr last))
|
||||||
(schedule-alarm (+ now ms) producer))))
|
(schedule-alarm (+ now ms) producer))))
|
||||||
beh ms-b)])
|
beh ms-b)]
|
||||||
|
[producer (proc->signal
|
||||||
|
(lambda ()
|
||||||
|
(let* ([now (and (signal? consumer) (current-inexact-milliseconds))]
|
||||||
|
[ms (value-now ms-b)])
|
||||||
|
(let loop ()
|
||||||
|
(if (or (empty? (mcdr head))
|
||||||
|
(< now (+ ms (cdr (mcar (mcdr head))))))
|
||||||
|
(let ([val (car (mcar head))])
|
||||||
|
(if (event-set? val)
|
||||||
|
(make-events-now (event-set-events val))
|
||||||
|
val))
|
||||||
|
(begin
|
||||||
|
(set! head (mcdr head))
|
||||||
|
(loop)))))))])
|
||||||
producer))
|
producer))
|
||||||
|
|
||||||
(define (inf-delay beh)
|
(define (inf-delay beh)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user