You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
public CallDurableFuture<{{{boxedOutputFqcn}}}> {{handlersClassMethodName}}({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
48
68
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
49
69
if (requestBuilderApplier != null) {
@@ -60,23 +80,35 @@ public class {{generatedClassSimpleName}} {
60
80
public class Send {
61
81
62
82
{{#handlers}}
83
+
/**
84
+
* @see {{originalClassFqcn}}#{{name}}
85
+
**/
63
86
public dev.restate.sdk.InvocationHandle<{{{boxedOutputFqcn}}}> {{handlersClassMethodName}}({{^inputEmpty}}{{{inputFqcn}}} req{{/inputEmpty}}) {
public dev.restate.sdk.InvocationHandle<{{{boxedOutputFqcn}}}> {{handlersClassMethodName}}({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
69
95
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}ContextClient.this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
70
96
if (requestBuilderApplier != null) {
71
97
requestBuilderApplier.accept(reqBuilder);
72
98
}
73
99
return ContextClient.this.ctx.send(reqBuilder);
74
100
}
101
+
/**
102
+
* @see {{originalClassFqcn}}#{{name}}
103
+
**/
75
104
public dev.restate.sdk.InvocationHandle<{{{boxedOutputFqcn}}}> {{handlersClassMethodName}}({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Duration delay) {
public dev.restate.sdk.InvocationHandle<{{{boxedOutputFqcn}}}> {{handlersClassMethodName}}({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Duration delay, Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
81
113
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}ContextClient.this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
82
114
if (requestBuilderApplier != null) {
@@ -88,6 +120,7 @@ public class {{generatedClassSimpleName}} {
88
120
}
89
121
}
90
122
123
+
/** Ingress client for {@link {{originalClassFqcn}} } **/
91
124
public static class IngressClient {
92
125
93
126
private final dev.restate.client.Client client;
@@ -106,18 +139,33 @@ public class {{generatedClassSimpleName}} {
106
139
{{outputSerdeRef}});
107
140
}
108
141
142
+
/**
143
+
* Submit the workflow.
144
+
*
145
+
* @see {{originalClassFqcn}}#{{name}}
146
+
**/
109
147
public dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}> submit({{^inputEmpty}}{{{inputFqcn}}} req{{/inputEmpty}}) {
public dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}> submit({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
122
170
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
123
171
if (requestBuilderApplier != null) {
@@ -126,6 +174,11 @@ public class {{generatedClassSimpleName}} {
public dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}> submit({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Duration delay, Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
130
183
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
131
184
if (requestBuilderApplier != null) {
@@ -134,18 +187,33 @@ public class {{generatedClassSimpleName}} {
public java.util.concurrent.CompletableFuture<dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}>> submitAsync({{^inputEmpty}}{{{inputFqcn}}} req{{/inputEmpty}}) {
public java.util.concurrent.CompletableFuture<dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}>> submitAsync({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
150
218
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
151
219
if (requestBuilderApplier != null) {
@@ -154,6 +222,11 @@ public class {{generatedClassSimpleName}} {
public java.util.concurrent.CompletableFuture<dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}>> submitAsync({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Duration delay, Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
158
231
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
159
232
if (requestBuilderApplier != null) {
@@ -162,11 +235,17 @@ public class {{generatedClassSimpleName}} {
public {{#ifoutputEmpty}}void{{else}}{{{outputFqcn}}}{{/if}}{{handlersClassMethodName}}({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
171
250
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
172
251
if (requestBuilderApplier != null) {
@@ -175,11 +254,17 @@ public class {{generatedClassSimpleName}} {
public {{#ifoutputEmpty}}java.util.concurrent.CompletableFuture<Void>{{else}}java.util.concurrent.CompletableFuture<{{{boxedOutputFqcn}}}>{{/if}}{{handlersClassMethodName}}Async({{^inputEmpty}}{{{inputFqcn}}} req{{/inputEmpty}}) {
public {{#ifoutputEmpty}}java.util.concurrent.CompletableFuture<Void>{{else}}java.util.concurrent.CompletableFuture<{{{boxedOutputFqcn}}}>{{/if}}{{handlersClassMethodName}}Async({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
184
269
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
185
270
if (requestBuilderApplier != null) {
@@ -196,23 +281,35 @@ public class {{generatedClassSimpleName}} {
196
281
public class Send {
197
282
198
283
{{#handlers}}{{^isWorkflow}}
284
+
/**
285
+
* @see {{originalClassFqcn}}#{{name}}
286
+
**/
199
287
public dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}> {{handlersClassMethodName}}({{^inputEmpty}}{{{inputFqcn}}} req{{/inputEmpty}}) {
public dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}> {{handlersClassMethodName}}({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
205
296
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}IngressClient.this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
public dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}> {{handlersClassMethodName}}({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Duration delay, Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
217
314
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}IngressClient.this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
218
315
if (requestBuilderApplier != null) {
@@ -221,23 +318,35 @@ public class {{generatedClassSimpleName}} {
public java.util.concurrent.CompletableFuture<dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}>> {{handlersClassMethodName}}Async({{^inputEmpty}}{{{inputFqcn}}} req{{/inputEmpty}}) {
public java.util.concurrent.CompletableFuture<dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}>> {{handlersClassMethodName}}Async({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
230
333
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}IngressClient.this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
public java.util.concurrent.CompletableFuture<dev.restate.client.SendResponse<{{{boxedOutputFqcn}}}>> {{handlersClassMethodName}}Async({{^inputEmpty}}{{{inputFqcn}}} req, {{/inputEmpty}}Duration delay, Consumer<dev.restate.common.RequestBuilder<{{{boxedInputFqcn}}}, {{{boxedOutputFqcn}}}>> requestBuilderApplier) {
242
351
var reqBuilder = {{../handlersClass}}.{{handlersClassMethodName}}({{#if../isKeyed}}IngressClient.this.key{{^inputEmpty}}, {{/inputEmpty}}{{/if}}{{^inputEmpty}}req{{/inputEmpty}});
0 commit comments