Function TestRunGroup

lib/gcppubsub/gcppubsubadapters/utils_test.go:24–101

(t *testing.T)

)

func TestRunGroup(t *testing.T) {
	tests := []struct {
		name        string
		fns         []func(context.Context) error
		expectedErr error
	}{
		{
			name: "All functions succeed",
			fns: []func(context.Context) error{
				func(_ context.Context) error { return nil },
				func(_ context.Context) error { return nil },
			},
			expectedErr: nil,
		},
		{
			name: "One function fails immediately",
			fns: []func(context.Context) error{
				func(_ context.Context) error { return errors.New("fail") },
				func(ctx context.Context) error {
					// Simulate work
					select {
					case <-ctx.Done():
						return ctx.Err()
					case <-time.After(100 * time.Millisecond):
						return nil
					}
				},
			},
			expectedErr: errors.New("fail"),
		},
		{
			name: "Multiple failures return first error",
			fns: []func(context.Context) error{
				func(_ context.Context) error { return errors.New("error 1") },
				func(_ context.Context) error {
					time.Sleep(10 * time.Millisecond) // Ensure this happens slightly later

					return errors.New("error 2")
				},
			},
			expectedErr: errors.New("error 1"),
		},
		{
			name: "Cancellation propagates",
			fns: []func(context.Context) error{
				func(_ context.Context) error {
					return errors.New("trigger cancel")
				},
				func(ctx context.Context) error {
					select {
					case <-ctx.Done():
						// Correct behavior: context was cancelled
						return nil
					case <-time.After(1 * time.Second):
						return errors.New("timeout: context was not cancelled")
					}
				},
			},