Function Test_Observable_Count_Parallel

observable_operator_test.go:376–382

(t *testing.T)

}

func Test_Observable_Count_Parallel(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	Assert(ctx, t, Range(1, 10000).Count(WithCPUPool()),
		HasItem(int64(10000)))
}

// FIXME
//func Test_Observable_Debounce(t *testing.T) {