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

Function testChannelConcurrentAccessors

channels_test.go:39–51  ·  view source on GitHub ↗
(t *testing.T, name string, ch Channel)

Source from the content-addressed store, hash-verified

37}
38
39func testChannelConcurrentAccessors(t *testing.T, name string, ch Channel) {
40 // no asserts here, this is just for the race detector's benefit
41 go ch.Len()
42 go ch.Cap()
43
44 go func() {
45 ch.In() <- nil
46 }()
47
48 go func() {
49 <-ch.Out()
50 }()
51}
52
53func TestPipe(t *testing.T) {
54 a := NewNativeChannel(None)

Callers 7

TestOverflowingChannelFunction · 0.85
TestRingChannelFunction · 0.85
TestBatchingChannelFunction · 0.85
TestNativeChannelsFunction · 0.85
TestDeadChannelFunction · 0.85
TestResizableChannelFunction · 0.85
TestInfiniteChannelFunction · 0.85

Calls 4

LenMethod · 0.65
CapMethod · 0.65
InMethod · 0.65
OutMethod · 0.65

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…