Function WeakPipe

channels.go:200–202

WeakPipe behaves like Pipe (connecting the two channels) except that it does not close the output channel when the input channel is closed.

(input SimpleOutChannel, output SimpleInChannel)

// WeakPipe behaves like Pipe (connecting the two channels) except that it does not close
// the output channel when the input channel is closed.
func WeakPipe(input SimpleOutChannel, output SimpleInChannel) {
	go pipe(input, output, false)
}

// WeakMultiplex behaves like Multiplex (multiplexing multiple inputs into a single output) except that it does not close
// the output channel when the input channels are closed.