// run is the main loop of the notifier.
func (n *notifier) run(ctx context.Context, success chan<- dispatchResult, failure chan<- dispatchResult) error {
...
 for {
    ...
    // Check if notifier is not paused.
    ok, err := n.ensureRunning(ctx)
    if err != nil {
	    n.log.Warn(ctx, "failed to check notifier state", slog.Error(err))
    }
    
    if ok {
            // <---- if the notifier was paused at this point, any pending messages would still be processed.

	    // Call process() immediately (i.e. don't wait an initial tick).
	    err = n.process(ctx, success, failure)
	    if err != nil {
		    n.log.Error(ctx, "failed to process messages", slog.Error(err))
	    }
    }
  ...
  }
...