diff --git a/libs/pubsub/pubsub_test.go b/libs/pubsub/pubsub_test.go index c72e56983..e1e616516 100644 --- a/libs/pubsub/pubsub_test.go +++ b/libs/pubsub/pubsub_test.go @@ -38,7 +38,7 @@ func TestSubscribe(t *testing.T) { assertReceive(t, "Quicksilver", subscription.Out()) } -func TestSubscribeWithOutCapacity(t *testing.T) { +func TestSubscribeWithoutCapacity(t *testing.T) { s := pubsub.NewServer() s.SetLogger(log.TestingLogger()) s.Start() diff --git a/rpc/lib/types/types.go b/rpc/lib/types/types.go index 1e7f4e120..d4e82b10c 100644 --- a/rpc/lib/types/types.go +++ b/rpc/lib/types/types.go @@ -251,7 +251,7 @@ type WSRPCContext struct { WSRPCConnection } -// EventSubscriber mirros tendermint/tendermint/types.EventBusSubscriber +// EventSubscriber mirrors tendermint/tendermint/types.EventBusSubscriber type EventSubscriber interface { Subscribe(ctx context.Context, subscriber string, query tmpubsub.Query, outCapacity ...int) (tmtypes.Subscription, error) Unsubscribe(ctx context.Context, subscriber string, query tmpubsub.Query) error