584
585
// PollNexusTaskQueue mocks base method.
586
>
func (m *MockMatchingServiceClient) PollNexusTaskQueue(ctx context.Context, in *matchingservice.PollNexusTaskQueueRequest, opts ...grpc.CallOption) (*matchingservice.PollNexusTaskQueueResponse, error) {
service_grpc.pb.mock.go
587
>
m.ctrl.T.Helper()
588
>
varargs := []any{ctx, in}
589
>
for _, a := range opts {
590
varargs = append(varargs, a)
591
}
593
>
ret0, _ := ret[0].(*matchingservice.PollNexusTaskQueueResponse)
594
>
ret1, _ := ret[1].(error)
595
>
return ret0, ret1
596
}
597
598
// PollNexusTaskQueue indicates an expected call of PollNexusTaskQueue.
599
>
func (mr *MockMatchingServiceClientMockRecorder) PollNexusTaskQueue(ctx, in any, opts ...any) *gomock.Call {
service_grpc.pb.mock.go
600
>
mr.mock.ctrl.T.Helper()
601
>
varargs := append([]any{ctx, in}, opts...)
602
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PollNexusTaskQueue", reflect.TypeOf((*MockMatchingServiceClient)(nil).PollNexusTaskQueue), varargs...)
603
>
}
604
605
// PollWorkflowTaskQueue mocks base method.