diff --git a/pkg/bus/bus.go b/pkg/bus/bus.go index 18652347e..763c652e0 100644 --- a/pkg/bus/bus.go +++ b/pkg/bus/bus.go @@ -148,7 +148,6 @@ func (mb *MessageBus) Close() { "count": drained, }) } - } func drain[T any](ch <-chan T) int {