|
|
@@ -141,7 +141,7 @@ func TestMuxConcurrent(t *testing.T) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func emptySubscriber(mux *TypeMux, types ...interface{}) {
|
|
|
+func emptySubscriber(mux *TypeMux) {
|
|
|
s := mux.Subscribe(testEvent(0))
|
|
|
go func() {
|
|
|
for range s.Chan() {
|
|
|
@@ -182,9 +182,9 @@ func BenchmarkPost1000(b *testing.B) {
|
|
|
func BenchmarkPostConcurrent(b *testing.B) {
|
|
|
var mux = new(TypeMux)
|
|
|
defer mux.Stop()
|
|
|
- emptySubscriber(mux, testEvent(0))
|
|
|
- emptySubscriber(mux, testEvent(0))
|
|
|
- emptySubscriber(mux, testEvent(0))
|
|
|
+ emptySubscriber(mux)
|
|
|
+ emptySubscriber(mux)
|
|
|
+ emptySubscriber(mux)
|
|
|
|
|
|
var wg sync.WaitGroup
|
|
|
poster := func() {
|