Function Test_Observable_ElementAt

observable_operator_test.go:585–591

(t *testing.T)

}

func Test_Observable_ElementAt(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	obs := Range(0, 10000).ElementAt(9999)
	Assert(ctx, t, obs, HasItems(9999))
}

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