Function testBatches

batching_channel_test.go:5–22

(t *testing.T, ch Channel)

import "testing"

func testBatches(t *testing.T, ch Channel) {
	go func() {
		for i := 0; i < 1000; i++ {
			ch.In() <- i
		}
		ch.Close()
	}()

	i := 0
	for val := range ch.Out() {
		for _, elem := range val.([]interface{}) {
			if i != elem.(int) {
				t.Fatal("batching channel expected", i, "but got", elem.(int))
			}
			i++
		}
	}
}

func TestBatchingChannel(t *testing.T) {
	ch := NewBatchingChannel(Infinity)