Function Test_Observable_First_Parallel_Empty

observable_operator_test.go:726–732

(t *testing.T)

}

func Test_Observable_First_Parallel_Empty(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	obs := Empty().First(WithCPUPool())
	Assert(ctx, t, obs, IsEmpty())
}

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