func NewStreamProxy()

in stream_proxy.go [12:16]

• 5 lines of code
• 1 McCabe index (conditional complexity)

func NewStreamProxy(stoppers int) *StreamProxy {
	return &StreamProxy{
		StopCh: make(chan error, stoppers+2), // each proxy() call is a stopper
	}
}