code: func NewProxyWatcher(ch chan Event) *ProxyWatcher {
  	return &ProxyWatcher{
  		result:  ch,
  		stopCh:  make(chan struct{}),
  		stopped: false,
  	}
  }
docs: // NewProxyWatcher creates new ProxyWatcher by wrapping a channel