aboutsummaryrefslogtreecommitdiffstats
path: root/event/event_test.go
diff options
context:
space:
mode:
authorFelix Lange <fjl@twurst.com>2014-10-17 00:10:09 +0800
committerFelix Lange <fjl@twurst.com>2014-10-17 00:50:48 +0800
commit690690489610352d43f8547744b6c9486ad5affa (patch)
tree2d8846b015d3e42b1daf1bd74ca40ef883bb9f5c /event/event_test.go
parent10bbf265b2e8f1906602d2604f755241b8eb49e6 (diff)
downloadgo-tangerine-690690489610352d43f8547744b6c9486ad5affa.tar
go-tangerine-690690489610352d43f8547744b6c9486ad5affa.tar.gz
go-tangerine-690690489610352d43f8547744b6c9486ad5affa.tar.bz2
go-tangerine-690690489610352d43f8547744b6c9486ad5affa.tar.lz
go-tangerine-690690489610352d43f8547744b6c9486ad5affa.tar.xz
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.go12
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))