Function newNotificationBatcher

api/stack_notification_batcher.go:39–47

(stackKey string, client *stacksapi.Client, logger *slog.Logger)

}

func newNotificationBatcher(stackKey string, client *stacksapi.Client, logger *slog.Logger) *notificationBatcher {
	nb := &notificationBatcher{
		notifications: make(chan stacksapi.StackNotification, maxBufferSize),
		stackKey:      stackKey,
		client:        client,
		logger:        logger,
	}
	return nb
}

func (nb *notificationBatcher) add(ctx context.Context, notification stacksapi.StackNotification) error {
	select {