more

Author: vietj

vertx-grpc-docs/src/main/java/examples/grpc/StreamingClient.java

@@ -137,6 +137,26 @@ static StreamingClient create(GrpcClient client, SocketAddress host, io.vertx.gr
   @io.vertx.codegen.annotations.GenIgnore(io.vertx.codegen.annotations.GenIgnore.PERMITTED_TYPE)
   Future<examples.grpc.Empty> sink(ReadStream<examples.grpc.Item> streamOfMessages);
 
+  /**
+   * Calls the Sink RPC service method.
+   *
+   * @param streamOfMessages a stream of messages to be sent to the service
+   * @return a future of the examples.grpc.Empty response message
+   */
+  @io.vertx.codegen.annotations.GenIgnore
+  default examples.grpc.Empty sink_sync(java.util.List<examples.grpc.Item> streamOfMessages) {
+    return sink_sync(streamOfMessages.iterator());
+  }
+
+  /**
+   * Calls the Sink RPC service method.
+   *
+   * @param streamOfMessages a stream of messages to be sent to the service
+   * @return a future of the examples.grpc.Empty response message
+   */
+  @io.vertx.codegen.annotations.GenIgnore
+  examples.grpc.Empty sink_sync(java.util.Iterator<examples.grpc.Item> streamOfMessages);
+
   /**
    * Calls the Pipe RPC service method.
    *
@@ -257,6 +277,10 @@ public Future<examples.grpc.Empty> sink(ReadStream<examples.grpc.Item> request)
     });
   }
 
+  public examples.grpc.Empty sink_sync(java.util.Iterator<examples.grpc.Item> request) {
+    throw new UnsupportedOperationException();
+  }
+
   public Future<ReadStream<examples.grpc.Item>> pipe(Completable<WriteStream<examples.grpc.Item>> completable) {
     ServiceMethod<examples.grpc.Item, examples.grpc.Item> serviceMethod;
     switch (wireFormat) {

vertx-grpc-protoc-plugin2/src/main/resources/client.mustache

@@ -121,6 +121,26 @@ public interface {{className}} {
    */
   @io.vertx.codegen.annotations.GenIgnore(io.vertx.codegen.annotations.GenIgnore.PERMITTED_TYPE)
   Future<{{outputType}}> {{vertxMethodName}}(ReadStream<{{inputType}}> streamOfMessages);
+
+  /**
+   * Calls the {{methodName}} RPC service method.
+   *
+   * @param streamOfMessages a stream of messages to be sent to the service
+   * @return a future of the {{outputType}} response message
+   */
+  @io.vertx.codegen.annotations.GenIgnore
+  default {{outputType}} {{vertxMethodName}}_sync(java.util.List<{{inputType}}> streamOfMessages) {
+    return {{vertxMethodName}}_sync(streamOfMessages.iterator());
+  }
+
+  /**
+   * Calls the {{methodName}} RPC service method.
+   *
+   * @param streamOfMessages a stream of messages to be sent to the service
+   * @return a future of the {{outputType}} response message
+   */
+  @io.vertx.codegen.annotations.GenIgnore
+  {{outputType}} {{vertxMethodName}}_sync(java.util.Iterator<{{inputType}}> streamOfMessages);
 {{/manyUnaryMethods}}
 {{#manyManyMethods}}
 
@@ -271,6 +291,10 @@ class {{className}}Impl implements {{className}} {
         }
     });
   }
+
+  public {{outputType}} {{vertxMethodName}}_sync(java.util.Iterator<{{inputType}}> request) {
+    throw new UnsupportedOperationException();
+  }
 {{/manyUnaryMethods}}
 {{#manyManyMethods}}