Skip to content

Commit 1c8ccff

Browse files
Leftover from previous signal API PR (#623)
1 parent 3ca3e29 commit 1c8ccff

1 file changed

Lines changed: 21 additions & 0 deletions

File tree

sdk-core/src/main/java/dev/restate/sdk/core/ExecutorSwitchingHandlerContextImpl.java

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,6 +162,27 @@ public CompletableFuture<AsyncResult<Void>> rejectPromise(String key, TerminalEx
162162
.thenCompose(Function.identity());
163163
}
164164

165+
@Override
166+
public CompletableFuture<AsyncResult<Slice>> signal(String name) {
167+
return CompletableFuture.supplyAsync(() -> super.signal(name), coreExecutor)
168+
.thenCompose(Function.identity());
169+
}
170+
171+
@Override
172+
public CompletableFuture<Void> resolveSignal(String invocationId, String name, Slice payload) {
173+
return CompletableFuture.supplyAsync(
174+
() -> super.resolveSignal(invocationId, name, payload), coreExecutor)
175+
.thenCompose(Function.identity());
176+
}
177+
178+
@Override
179+
public CompletableFuture<Void> rejectSignal(
180+
String invocationId, String name, TerminalException reason) {
181+
return CompletableFuture.supplyAsync(
182+
() -> super.rejectSignal(invocationId, name, reason), coreExecutor)
183+
.thenCompose(Function.identity());
184+
}
185+
165186
@Override
166187
public void proposeRunSuccess(int runHandle, Slice toWrite) {
167188
coreExecutor.execute(() -> super.proposeRunSuccess(runHandle, toWrite));

0 commit comments

Comments
 (0)