Function Test_Observable_Contain_Parallel

observable_operator_test.go:347–366

(t *testing.T)

}

func Test_Observable_Contain_Parallel(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	predicate := func(i interface{}) bool {
		switch i := i.(type) {
		case int:
			return i == 2
		default:
			return false
		}
	}

	Assert(ctx, t,
		testObservable(ctx, 1, 2, 3).Contains(predicate, WithContext(ctx), WithCPUPool()),
		HasItem(true))
	Assert(ctx, t,
		testObservable(ctx, 1, 5, 3).Contains(predicate, WithContext(ctx), WithCPUPool()),
		HasItem(false))
}

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