Function TestBatchingChannelCap

batching_channel_test.go:35–45

(t *testing.T)

}

func TestBatchingChannelCap(t *testing.T) {
	ch := NewBatchingChannel(Infinity)
	if ch.Cap() != Infinity {
		t.Error("incorrect capacity on infinite channel")
	}

	ch = NewBatchingChannel(5)
	if ch.Cap() != 5 {
		t.Error("incorrect capacity on infinite channel")
	}
}