Function getChannel

observable_operator_random_test.go:124–135

(ctx context.Context)

}

func getChannel(ctx context.Context) chan Item {
	ch := make(chan Item, 3)
	go func() {
		time.Sleep(randomTime())
		Of(1).SendContext(ctx, ch)
		time.Sleep(randomTime())
		Of(2).SendContext(ctx, ch)
		time.Sleep(randomTime())
		Of(3).SendContext(ctx, ch)
	}()
	return ch
}

func randomTime() time.Duration {
	return time.Duration(rand.Intn(maxSleepNs)) * time.Nanosecond