Function Test_Observable_GroupBy_Error

observable_operator_test.go:936–957

(t *testing.T)

}

func Test_Observable_GroupBy_Error(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	length := 3
	count := 11

	obs := Range(0, count).GroupBy(length, func(item Item) int {
		return 4
	}, WithBufferedChannel(count))
	s, err := obs.ToSlice(0)
	if err != nil {
		assert.FailNow(t, err.Error())
	}
	if len(s) != length {
		assert.FailNow(t, "length", "got=%d, expected=%d", len(s), length)
	}

	Assert(ctx, t, s[0].(Observable), HasAnError())
	Assert(ctx, t, s[1].(Observable), HasAnError())
	Assert(ctx, t, s[2].(Observable), HasAnError())
}

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