diff options
| author | Felix Lange <fjl@twurst.com> | 2014-10-17 00:10:09 +0800 |
|---|---|---|
| committer | Felix Lange <fjl@twurst.com> | 2014-10-17 00:50:48 +0800 |
| commit | 690690489610352d43f8547744b6c9486ad5affa (patch) | |
| tree | 2d8846b015d3e42b1daf1bd74ca40ef883bb9f5c /event/event_test.go | |
| parent | 10bbf265b2e8f1906602d2604f755241b8eb49e6 (diff) | |
| download | go-tangerine-690690489610352d43f8547744b6c9486ad5affa.tar.gz go-tangerine-690690489610352d43f8547744b6c9486ad5affa.tar.zst go-tangerine-690690489610352d43f8547744b6c9486ad5affa.zip | |
event: make TypeMux zero value ready to use
Diffstat (limited to 'event/event_test.go')
| -rw-r--r-- | event/event_test.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/event/event_test.go b/event/event_test.go index 385bd70b7..f65aaa0a2 100644 --- a/event/event_test.go +++ b/event/event_test.go @@ -10,7 +10,7 @@ import ( type testEvent int func TestSub(t *testing.T) { - mux := NewTypeMux() + mux := new(TypeMux) defer mux.Stop() sub := mux.Subscribe(testEvent(0)) @@ -28,7 +28,7 @@ func TestSub(t *testing.T) { } func TestMuxErrorAfterStop(t *testing.T) { - mux := NewTypeMux() + mux := new(TypeMux) mux.Stop() sub := mux.Subscribe(testEvent(0)) @@ -41,7 +41,7 @@ func TestMuxErrorAfterStop(t *testing.T) { } func TestUnsubscribeUnblockPost(t *testing.T) { - mux := NewTypeMux() + mux := new(TypeMux) defer mux.Stop() sub := mux.Subscribe(testEvent(0)) @@ -62,7 +62,7 @@ func TestUnsubscribeUnblockPost(t *testing.T) { func TestMuxConcurrent(t *testing.T) { rand.Seed(time.Now().Unix()) - mux := NewTypeMux() + mux := new(TypeMux) defer mux.Stop() recv := make(chan int) @@ -111,7 +111,7 @@ func emptySubscriber(mux *TypeMux, types ...interface{}) { } func BenchmarkPost3(b *testing.B) { - var mux = NewTypeMux() + var mux = new(TypeMux) defer mux.Stop() emptySubscriber(mux, testEvent(0)) emptySubscriber(mux, testEvent(0)) @@ -123,7 +123,7 @@ func BenchmarkPost3(b *testing.B) { } func BenchmarkPostConcurrent(b *testing.B) { - var mux = NewTypeMux() + var mux = new(TypeMux) defer mux.Stop() emptySubscriber(mux, testEvent(0)) emptySubscriber(mux, testEvent(0)) |