@@ -237,11 +237,11 @@ func setupSubscriber[T any](
237 case <-time.After(2 * time.Second):
237 case <-time.After(2 * time.Second):
238 slog.Warn("message dropped due to slow consumer", "name", name)
238 slog.Warn("message dropped due to slow consumer", "name", name)
239 case <-ctx.Done():
239 case <-ctx.Done():
240− slog.Info("subscription cancelled", "name", name)
240+ slog.Info("subscription canceled", "name", name)
243 case <-ctx.Done():
243 case <-ctx.Done():
244− slog.Info("subscription cancelled", "name", name)
244+ slog.Info("subscription canceled", "name", name)