MCPcopy Create free account
hub / github.com/eapache/channels / TestBatchingChannel

Function TestBatchingChannel

batching_channel_test.go:24–33  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

22}
23
24func TestBatchingChannel(t *testing.T) {
25 ch := NewBatchingChannel(Infinity)
26 testBatches(t, ch)
27
28 ch = NewBatchingChannel(2)
29 testBatches(t, ch)
30
31 ch = NewBatchingChannel(1)
32 testChannelConcurrentAccessors(t, "batching channel", ch)
33}
34
35func TestBatchingChannelCap(t *testing.T) {
36 ch := NewBatchingChannel(Infinity)

Callers

nothing calls this directly

Calls 3

NewBatchingChannelFunction · 0.85
testBatchesFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…