docs: public Flux<ServiceMessage> requestMany(
        ServiceMessage request, Class<?> responseType, Address address) {
      return Flux.defer(
          () -> {
            requireNonNull(address, "requestMany address parameter is required and must not be null");
            requireNonNull(transport, "transport is required and must not be null");
            return transport
                .create(address)
                .requestStream(request)
                .map(message -> ServiceMessageCodec.decodeData(message, responseType))
                .map(this::throwIfError);
          });
    }