diff --git a/wait/wait.go b/wait/wait.go index 4611c4a3b..dcf61c6d3 100644 --- a/wait/wait.go +++ b/wait/wait.go @@ -2,16 +2,16 @@ package wait import "sync" -type Waiter struct { +type WaitList struct { l sync.Mutex m map[int64]chan interface{} } -func New() Waiter { - return Waiter{m: make(map[int64]chan interface{})} +func New() WaitList { + return WaitList{m: make(map[int64]chan interface{})} } -func (w Waiter) Register(id int64) <-chan interface{} { +func (w WaitList) Register(id int64) <-chan interface{} { w.l.Lock() defer w.l.Unlock() ch := w.m[id] @@ -22,7 +22,7 @@ func (w Waiter) Register(id int64) <-chan interface{} { return ch } -func (w Waiter) Trigger(id int64, x interface{}) { +func (w WaitList) Trigger(id int64, x interface{}) { w.l.Lock() ch := w.m[id] delete(w.m, id)