1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
package fakeclock_test
import (
"time"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
"github.com/pivotal-golang/clock/fakeclock"
)
var _ = Describe("FakeTimer", func() {
const Δ = 10 * time.Millisecond
var (
fakeClock *fakeclock.FakeClock
initialTime time.Time
)
BeforeEach(func() {
initialTime = time.Date(2014, 1, 1, 3, 0, 30, 0, time.UTC)
fakeClock = fakeclock.NewFakeClock(initialTime)
})
It("proivdes a channel that receives after the given interval has elapsed", func() {
timer := fakeClock.NewTimer(10 * time.Second)
timeChan := timer.C()
Consistently(timeChan, Δ).ShouldNot(Receive())
fakeClock.Increment(5 * time.Second)
Consistently(timeChan, Δ).ShouldNot(Receive())
fakeClock.Increment(4 * time.Second)
Consistently(timeChan, Δ).ShouldNot(Receive())
fakeClock.Increment(1 * time.Second)
Eventually(timeChan).Should(Receive(Equal(initialTime.Add(10 * time.Second))))
fakeClock.Increment(10 * time.Second)
Consistently(timeChan, Δ).ShouldNot(Receive())
})
Describe("WaitForWatcherAndIncrement", func() {
It("consistently fires timers that start asynchronously", func() {
received := make(chan time.Time)
stop := make(chan struct{})
defer close(stop)
duration := 10 * time.Second
go func() {
for {
timer := fakeClock.NewTimer(duration)
select {
case ticked := <-timer.C():
received <- ticked
case <-stop:
return
}
}
}()
for i := 0; i < 100; i++ {
fakeClock.WaitForWatcherAndIncrement(duration)
Expect((<-received).Sub(initialTime)).To(Equal(duration * time.Duration(i+1)))
}
})
})
})
|
