Function Test_Observable_WindowWithCount

observable_operator_test.go:2267–2275

(t *testing.T)

}

func Test_Observable_WindowWithCount(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	observe := testObservable(ctx, 1, 2, 3, 4, 5).WindowWithCount(2).Observe()
	Assert(ctx, t, (<-observe).V.(Observable), HasItems(1, 2))
	Assert(ctx, t, (<-observe).V.(Observable), HasItems(3, 4))
	Assert(ctx, t, (<-observe).V.(Observable), HasItems(5))
}

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