Function Test_Observable_FlatMap_Error1

observable_operator_test.go:776–787

(t *testing.T)

}

func Test_Observable_FlatMap_Error1(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	obs := testObservable(ctx, 1, 2, 3).FlatMap(func(i Item) Observable {
		if i.V == 2 {
			return testObservable(ctx, errFoo)
		}
		return testObservable(ctx, i.V.(int)+1, i.V.(int)*10)
	})
	Assert(ctx, t, obs, HasItems(2, 10), HasError(errFoo))
}

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