From e2d8e1868b5d8507bdb9eafa27777ce5f5b24e21 Mon Sep 17 00:00:00 2001 From: Blake Mizerany Date: Tue, 19 Aug 2014 16:46:36 -0700 Subject: [PATCH] wait: Waiter -> WaitList --- wait/wait.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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)