Function Test_Observable_Take_Interval

observable_operator_test.go:2040–2051

(t *testing.T)

}

func Test_Observable_Take_Interval(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	obs := Interval(WithDuration(time.Nanosecond), WithContext(ctx)).Take(3)
	Assert(ctx, t, obs, CustomPredicate(func(items []interface{}) error {
		if len(items) != 3 {
			return errors.New("3 items are expected")
		}
		return nil
	}))
}

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