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

Function TestWeakPipe

channels_test.go:62–69  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

60}
61
62func TestWeakPipe(t *testing.T) {
63 a := NewNativeChannel(None)
64 b := NewNativeChannel(None)
65
66 WeakPipe(a, b)
67
68 testChannelPair(t, "pipe", a, b)
69}
70
71func testMultiplex(t *testing.T, multi func(output SimpleInChannel, inputs ...SimpleOutChannel)) {
72 a := NewNativeChannel(None)

Callers

nothing calls this directly

Calls 3

NewNativeChannelFunction · 0.85
WeakPipeFunction · 0.85
testChannelPairFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…