Remove unused channels from mock
@@ -8,14 +8,6 @@ import (
)
type mockDopplerServer struct {
- SubscribeCalled chan bool
- SubscribeInput struct {
- Req chan *plumbing.SubscriptionRequest
- Stream chan plumbing.Doppler_SubscribeServer
- }
- SubscribeOutput struct {
- Err chan error
- }
BatchSubscribeCalled chan bool
BatchSubscribeInput struct {
Req chan *plumbing.SubscriptionRequest
@@ -46,10 +38,6 @@ type mockDopplerServer struct {
func newMockDopplerServer() *mockDopplerServer {
m := &mockDopplerServer{}
- m.SubscribeCalled = make(chan bool, 100)
- m.SubscribeInput.Req = make(chan *plumbing.SubscriptionRequest, 100)
- m.SubscribeInput.Stream = make(chan plumbing.Doppler_SubscribeServer, 100)
- m.SubscribeOutput.Err = make(chan error, 100)
m.BatchSubscribeCalled = make(chan bool, 100)
m.BatchSubscribeInput.Req = make(chan *plumbing.SubscriptionRequest, 100)
m.BatchSubscribeInput.Stream = make(chan plumbing.Doppler_BatchSubscribeServer, 100)
@@ -67,10 +55,7 @@ func newMockDopplerServer() *mockDopplerServer {
return m
}
func (m *mockDopplerServer) Subscribe(req *plumbing.SubscriptionRequest, stream plumbing.Doppler_SubscribeServer) (err error) {
- m.SubscribeCalled <- true
- m.SubscribeInput.Req <- req
- m.SubscribeInput.Stream <- stream
- return <-m.SubscribeOutput.Err
+ panic("deprecated - not implemented")
}
func (m *mockDopplerServer) BatchSubscribe(req *plumbing.SubscriptionRequest, stream plumbing.Doppler_BatchSubscribeServer) (err error) {
