SubscribeWithErr mocks base method.
(event string, listener pubsub.ListenerWithErr)
| 85 | |
| 86 | // SubscribeWithErr mocks base method. |
| 87 | func (m *MockPubsub) SubscribeWithErr(event string, listener pubsub.ListenerWithErr) (func(), error) { |
| 88 | m.ctrl.T.Helper() |
| 89 | ret := m.ctrl.Call(m, "SubscribeWithErr", event, listener) |
| 90 | ret0, _ := ret[0].(func()) |
| 91 | ret1, _ := ret[1].(error) |
| 92 | return ret0, ret1 |
| 93 | } |
| 94 | |
| 95 | // SubscribeWithErr indicates an expected call of SubscribeWithErr. |
| 96 | func (mr *MockPubsubMockRecorder) SubscribeWithErr(event, listener any) *gomock.Call { |