Function Test_Observable_BufferWithCount_Error

observable_operator_test.go:258–264

(t *testing.T)

}

func Test_Observable_BufferWithCount_Error(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	obs := testObservable(ctx, 1, 2, 3, 4, errFoo).BufferWithCount(3)
	Assert(ctx, t, obs, HasItems([]interface{}{1, 2, 3}, []interface{}{4}), HasError(errFoo))
}

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