11package examples ;
22
3+ import io .vertx .codegen .annotations .GenIgnore ;
4+ import io .vertx .codegen .annotations .VertxGen ;
35import io .vertx .core .Future ;
46import io .vertx .core .Completable ;
57import io .vertx .core .Handler ;
1820/**
1921 * <p>A client for invoking the Streaming gRPC service.</p>
2022 */
21- @ io . vertx . codegen . annotations . VertxGen
23+ @ VertxGen
2224public interface StreamingClient {
2325
2426 /**
2527 * Source protobuf RPC client service method.
2628 */
27- @ io . vertx . codegen . annotations . GenIgnore (io . vertx . codegen . annotations . GenIgnore .PERMITTED_TYPE )
29+ @ GenIgnore (GenIgnore .PERMITTED_TYPE )
2830 ServiceMethod <examples .Item , examples .Empty > Source = ServiceMethod .client (
2931 ServiceName .create ("streaming" , "Streaming" ),
3032 "Source" ,
@@ -34,7 +36,7 @@ public interface StreamingClient {
3436 /**
3537 * Sink protobuf RPC client service method.
3638 */
37- @ io . vertx . codegen . annotations . GenIgnore (io . vertx . codegen . annotations . GenIgnore .PERMITTED_TYPE )
39+ @ GenIgnore (GenIgnore .PERMITTED_TYPE )
3840 ServiceMethod <examples .Empty , examples .Item > Sink = ServiceMethod .client (
3941 ServiceName .create ("streaming" , "Streaming" ),
4042 "Sink" ,
@@ -44,7 +46,7 @@ public interface StreamingClient {
4446 /**
4547 * Pipe protobuf RPC client service method.
4648 */
47- @ io . vertx . codegen . annotations . GenIgnore (io . vertx . codegen . annotations . GenIgnore .PERMITTED_TYPE )
49+ @ GenIgnore (GenIgnore .PERMITTED_TYPE )
4850 ServiceMethod <examples .Item , examples .Item > Pipe = ServiceMethod .client (
4951 ServiceName .create ("streaming" , "Streaming" ),
5052 "Pipe" ,
@@ -54,7 +56,7 @@ public interface StreamingClient {
5456 /**
5557 * Json client service methods.
5658 */
57- @ io . vertx . codegen . annotations . GenIgnore (io . vertx . codegen . annotations . GenIgnore .PERMITTED_TYPE )
59+ @ GenIgnore (GenIgnore .PERMITTED_TYPE )
5860 final class Json {
5961
6062 /**
@@ -114,10 +116,10 @@ static StreamingClient create(GrpcClient client, SocketAddress host, io.vertx.gr
114116 * @param request the examples.Empty request message
115117 * @return a future of the examples.Item response messages
116118 */
117- @ io . vertx . codegen . annotations . GenIgnore (io . vertx . codegen . annotations . GenIgnore .PERMITTED_TYPE )
119+ @ GenIgnore (GenIgnore .PERMITTED_TYPE )
118120 Future <ReadStream <examples .Item >> source (examples .Empty request );
119121
120- @ io . vertx . codegen . annotations . GenIgnore
122+ @ GenIgnore
121123 Stream <examples .Item > source_sync (examples .Empty request );
122124
123125 /**
@@ -126,7 +128,7 @@ static StreamingClient create(GrpcClient client, SocketAddress host, io.vertx.gr
126128 * @param completable a completable that will be passed a stream to which the examples.Item request messages can be written to.
127129 * @return a future of the examples.Empty response message
128130 */
129- @ io . vertx . codegen . annotations . GenIgnore
131+ @ GenIgnore
130132 Future <examples .Empty > sink (Completable <WriteStream <examples .Item >> completable );
131133
132134 /**
@@ -135,7 +137,7 @@ static StreamingClient create(GrpcClient client, SocketAddress host, io.vertx.gr
135137 * @param streamOfMessages a stream of messages to be sent to the service
136138 * @return a future of the examples.Empty response message
137139 */
138- @ io . vertx . codegen . annotations . GenIgnore (io . vertx . codegen . annotations . GenIgnore .PERMITTED_TYPE )
140+ @ GenIgnore (GenIgnore .PERMITTED_TYPE )
139141 Future <examples .Empty > sink (ReadStream <examples .Item > streamOfMessages );
140142
141143 /**
@@ -144,7 +146,7 @@ static StreamingClient create(GrpcClient client, SocketAddress host, io.vertx.gr
144146 * @param streamOfMessages a stream of messages to be sent to the service
145147 * @return a future of the examples.Empty response message
146148 */
147- @ io . vertx . codegen . annotations . GenIgnore
149+ @ GenIgnore
148150 default examples .Empty sink_sync (java .util .List <examples .Item > streamOfMessages ) {
149151 return sink_sync (streamOfMessages .iterator ());
150152 }
@@ -155,7 +157,7 @@ default examples.Empty sink_sync(java.util.List<examples.Item> streamOfMessages)
155157 * @param streamOfMessages a stream of messages to be sent to the service
156158 * @return a future of the examples.Empty response message
157159 */
158- @ io . vertx . codegen . annotations . GenIgnore
160+ @ GenIgnore
159161 examples .Empty sink_sync (java .util .Iterator <examples .Item > streamOfMessages );
160162
161163 /**
@@ -164,7 +166,7 @@ default examples.Empty sink_sync(java.util.List<examples.Item> streamOfMessages)
164166 * @param compltable a completable that will be passed a stream to which the examples.Item request messages can be written to.
165167 * @return a future of the examples.Item response messages
166168 */
167- @ io . vertx . codegen . annotations . GenIgnore
169+ @ GenIgnore
168170 Future <ReadStream <examples .Item >> pipe (Completable <WriteStream <examples .Item >> completable );
169171
170172 /**
@@ -173,7 +175,7 @@ default examples.Empty sink_sync(java.util.List<examples.Item> streamOfMessages)
173175 * @param streamOfMessages a stream of messages to be sent to the service
174176 * @return a future of the examples.Item response messages
175177 */
176- @ io . vertx . codegen . annotations . GenIgnore (io . vertx . codegen . annotations . GenIgnore .PERMITTED_TYPE )
178+ @ GenIgnore (GenIgnore .PERMITTED_TYPE )
177179 Future <ReadStream <examples .Item >> pipe (ReadStream <examples .Item > streamOfMessages );
178180}
179181
0 commit comments