code: func NewBodyWatcher(req *http.Request, client *http.Client) (Watch, error) {
  	stop := make(chan struct{})
  	req.Cancel = stop
  
  	res, err := client.Do(req)
  	if err != nil {
  		return nil, err
  	}
  
  	wr := &bodyWatcher{
  		results: make(chan Event),
  		stop:    stop,
  		req:     req,
  		res:     res,
  	}
  
  	go wr.stream()
  	return wr, nil
  }
docs: // NewBodyWatcher creates a k8s body watcher for
  // a given http request