124
125
// CancelOutstandingWorkerPolls mocks base method.
126
>
func (m *MockMatchingServiceClient) CancelOutstandingWorkerPolls(ctx context.Context, in *matchingservice.CancelOutstandingWorkerPollsRequest, opts ...grpc.CallOption) (*matchingservice.CancelOutstandingWorkerPollsResponse, error) {
service_grpc.pb.mock.go
127
>
m.ctrl.T.Helper()
128
>
varargs := []any{ctx, in}
129
>
for _, a := range opts {
130
varargs = append(varargs, a)
131
}
133
>
ret0, _ := ret[0].(*matchingservice.CancelOutstandingWorkerPollsResponse)
134
>
ret1, _ := ret[1].(error)
135
>
return ret0, ret1
136
}
137
138
// CancelOutstandingWorkerPolls indicates an expected call of CancelOutstandingWorkerPolls.
139
>
func (mr *MockMatchingServiceClientMockRecorder) CancelOutstandingWorkerPolls(ctx, in any, opts ...any) *gomock.Call {
service_grpc.pb.mock.go
140
>
mr.mock.ctrl.T.Helper()
141
>
varargs := append([]any{ctx, in}, opts...)
142
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CancelOutstandingWorkerPolls", reflect.TypeOf((*MockMatchingServiceClient)(nil).CancelOutstandingWorkerPolls), varargs...)
143
>
}
144
145
// CancelOutstandingWorkerPollsPartition mocks base method.