  @Test
  @DisplayName("invokeMany should return error response when service throws exception")
  void testInvokeManyWhenThrowException() throws Exception {

    final String methodName = "throwException2";
    final Class<? extends StubService> serviceClass = stubService.getClass();
    final Method method = serviceClass.getMethod(methodName);

    final MethodInfo methodInfo =
        new MethodInfo(
            serviceClass.getName(),
            methodName,
            method.getReturnType(),
            CommunicationMode.REQUEST_STREAM,
            method.getParameterCount(),
            Void.TYPE);

    serviceMethodInvoker = new ServiceMethodInvoker(method, stubService, methodInfo);

    ServiceMessage message =
        ServiceMessage.builder().qualifier(qualifierPrefix + methodName).streamId("1").build();

    final Flux<ServiceMessage> invokeOne = serviceMethodInvoker.invokeMany(message, dataDecoder);

    StepVerifier.create(invokeOne).verifyError(RuntimeException.class);
  }