Unsubscribe mocks base method
(topic string, ch <-chan interface{})
| 63 | |
| 64 | // Unsubscribe mocks base method |
| 65 | func (m *MockPubsub) Unsubscribe(topic string, ch <-chan interface{}) error { |
| 66 | m.ctrl.T.Helper() |
| 67 | ret := m.ctrl.Call(m, "Unsubscribe", topic, ch) |
| 68 | ret0, _ := ret[0].(error) |
| 69 | return ret0 |
| 70 | } |
| 71 | |
| 72 | // Unsubscribe indicates an expected call of Unsubscribe |
| 73 | func (mr *MockPubsubMockRecorder) Unsubscribe(topic, ch interface{}) *gomock.Call { |
no outgoing calls