-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathreal.go
69 lines (53 loc) · 1.12 KB
/
real.go
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
package clock
import (
"time"
)
type realClock struct{}
func NewRealClock() Clock {
return realClock{}
}
// Now returns the current local time.
func (realClock) Now() time.Time {
return time.Now()
}
func (realClock) Since(t time.Time) time.Duration {
return time.Since(t)
}
func (realClock) Sleep(d time.Duration) {
time.Sleep(d)
}
func (realClock) Tick(d time.Duration) func() <-chan time.Time {
// nolint: staticcheck
c := time.Tick(d)
return func() <-chan time.Time { return c }
}
func (realClock) After(d time.Duration) <-chan time.Time {
return time.After(d)
}
type realTimer struct {
*time.Timer
}
func (timer realTimer) C() <-chan time.Time {
return timer.Timer.C
}
func (realClock) AfterFunc(d time.Duration, f func()) Timer {
return realTimer{
Timer: time.AfterFunc(d, f),
}
}
func (r realClock) NewTimer(d time.Duration) Timer {
return realTimer{
Timer: time.NewTimer(d),
}
}
type realTicker struct {
*time.Ticker
}
func (ticker realTicker) C() <-chan time.Time {
return ticker.Ticker.C
}
func (r realClock) NewTicker(d time.Duration) Ticker {
return realTicker{
Ticker: time.NewTicker(d),
}
}