Function Test_FromEventSource_Drop

factory_test.go:334–356

(t *testing.T)

}

func Test_FromEventSource_Drop(t *testing.T) {
	defer goleak.VerifyNone(t)
	const max = 100000
	next := make(chan Item, max)
	obs := FromEventSource(next, WithBackPressureStrategy(Drop))

	go func() {
		for i := 0; i < max; i++ {
			next <- Of(i)
		}
		close(next)
	}()

	Assert(context.Background(), t, obs, CustomPredicate(func(items []interface{}) error {
		if len(items) == max {
			return errors.New("some items should be dropped")
		}
		if len(items) == 0 {
			return errors.New("no items")
		}
		return nil
	}))
}

// FIXME
//func Test_Interval(t *testing.T) {