func (wr *bodyWatcher) Stop() {
	select {
	case <-wr.stop:
		return
	default:
		wr.cancel()
		close(wr.stop)
	}
}
Stop cancels the request
package client
import (
	"bufio"
	"context"
	"encoding/json"
	"errors"
	"net/http"
	"github.com/micro/micro/v3/service/runtime/kubernetes/api"
)
const (
	Added    EventType = "ADDED"
	Modified EventType = "MODIFIED"
	Deleted  EventType = "DELETED"
	Error    EventType = "ERROR"
)
type Watcher interface {
	Chan() <-chan Event
	Stop()
}
type EventType string
type Event struct {
	Type   EventType       `json:"type"`
	Object json.RawMessage `json:"object"`
}
type bodyWatcher struct {
	results chan Event
	cancel  func()
	stop    chan bool
	res     *http.Response
	req     *api.Request
}
func (wr *bodyWatcher) Chan() <-chan Event {
	return wr.results
}