Function Test_Observable_Distinct_Parallel_Error2

observable_operator_test.go:486–497

(t *testing.T)

}

func Test_Observable_Distinct_Parallel_Error2(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	obs := testObservable(ctx, 1, 2, 2, 2, 3, 4).Distinct(func(_ context.Context, item interface{}) (interface{}, error) {
		if item.(int) == 3 {
			return nil, errFoo
		}
		return item, nil
	}, WithContext(ctx), WithCPUPool())
	Assert(ctx, t, obs, HasError(errFoo))
}

func Test_Observable_DistinctUntilChanged(t *testing.T) {
	defer goleak.VerifyNone(t)