no timeout

libs/pubsub/pubsub.go

@@ -38,7 +38,6 @@ import (
 	"context"
 	"errors"
 	"sync"
-	"time"
 
 	cmn "github.com/tendermint/tendermint/libs/common"
 )
@@ -395,7 +394,7 @@ func (state *state) send(msg interface{}, tags map[string]string) {
 					// don't block on buffered channels
 					select {
 					case subscription.out <- Message{msg, tags}:
-					case <-time.After(100 * time.Millisecond):
+					default:
 						state.remove(clientID, qStr, ErrOutOfCapacity)
 					}
 				}

types/event_bus_test.go

@@ -139,10 +139,11 @@ func TestEventBusPublish(t *testing.T) {
 	require.NoError(t, err)
 	defer eventBus.Stop()
 
-	sub, err := eventBus.Subscribe(context.Background(), "test", tmquery.Empty{})
+	const numEventsExpected = 14
+
+	sub, err := eventBus.Subscribe(context.Background(), "test", tmquery.Empty{}, numEventsExpected)
 	require.NoError(t, err)
 
-	const numEventsExpected = 14
 	done := make(chan struct{})
 	go func() {
 		numEvents := 0