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

Function Pipe

channels.go:163–165  ·  view source on GitHub ↗

Pipe connects the input channel to the output channel so that they behave as if a single channel.

(input SimpleOutChannel, output SimpleInChannel)

Source from the content-addressed store, hash-verified

161// Pipe connects the input channel to the output channel so that
162// they behave as if a single channel.
163func Pipe(input SimpleOutChannel, output SimpleInChannel) {
164 go pipe(input, output, true)
165}
166
167// Multiplex takes an arbitrary number of input channels and multiplexes their output into a single output
168// channel. When all input channels have been closed, the output channel is closed. Multiplex with a single

Callers 3

ExampleSharedBufferFunction · 0.85
TestNativeInOutChannelsFunction · 0.85
TestPipeFunction · 0.85

Calls 1

pipeFunction · 0.85

Tested by 3

ExampleSharedBufferFunction · 0.68
TestNativeInOutChannelsFunction · 0.68
TestPipeFunction · 0.68

Used in the wild real call sites across dependent graphs

searching dependent graphs…