Skip to content

Commit d1cd542

Browse files
Code review
1 parent acfa2e8 commit d1cd542

3 files changed

Lines changed: 10 additions & 7 deletions

File tree

temporal-sdk/src/main/java/io/temporal/internal/nexus/NexusStartWorkflowHelper.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,8 @@
1616

1717
/**
1818
* Shared helper for starting a workflow from a Nexus operation and attaching workflow links to the
19-
* operation context. Used by both {@code WorkflowRunOperationImpl} and {@code TemporalNexusClient}.
19+
* operation context. Used by both {@code WorkflowRunOperationImpl} and {@code
20+
* TemporalNexusClientImpl}.
2021
*/
2122
public class NexusStartWorkflowHelper {
2223

temporal-sdk/src/main/java/io/temporal/nexus/TemporalNexusClientImpl.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,12 +5,14 @@
55
import io.temporal.client.WorkflowClient;
66
import io.temporal.client.WorkflowOptions;
77
import io.temporal.client.WorkflowStub;
8+
import io.temporal.common.Experimental;
89
import io.temporal.internal.client.NexusStartWorkflowResponse;
910
import io.temporal.internal.nexus.NexusStartWorkflowHelper;
1011
import io.temporal.workflow.Functions;
1112
import java.util.Objects;
1213

1314
/** Package-private implementation of {@link TemporalNexusClient}. */
15+
@Experimental
1416
final class TemporalNexusClientImpl implements TemporalNexusClient {
1517

1618
private final WorkflowClient client;

temporal-sdk/src/main/java/io/temporal/nexus/TemporalOperationHandler.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,13 @@
1818
*
1919
* <pre>{@code
2020
* @OperationImpl
21-
* public OperationHandler<OrderInput, OrderResult> createOrder() {
21+
* public OperationHandler<TransferInput, TransferResult> startTransfer() {
2222
* return TemporalOperationHandler.from((context, client, input) -> {
2323
* return client.startWorkflow(
24-
* OrderWorkflow.class,
25-
* wf -> wf.processOrder(input),
24+
* TransferWorkflow.class,
25+
* TransferWorkflow::transfer, input.getFromAccount(), input.getToAccount(),
2626
* WorkflowOptions.newBuilder()
27-
* .setWorkflowId("order-" + input.getOrderId())
27+
* .setWorkflowId("transfer-" + input.getTransferId())
2828
* .build());
2929
* });
3030
* }
@@ -70,7 +70,7 @@ public static <T, R> TemporalOperationHandler<T, R> from(StartFunction<T, R> sta
7070
}
7171

7272
@Override
73-
public OperationStartResult<R> start(
73+
public final OperationStartResult<R> start(
7474
OperationContext ctx, OperationStartDetails details, T input) {
7575
InternalNexusOperationContext nexusCtx = CurrentNexusOperationContext.get();
7676
TemporalNexusClient client =
@@ -91,7 +91,7 @@ public OperationStartResult<R> start(
9191
}
9292

9393
@Override
94-
public void cancel(OperationContext ctx, OperationCancelDetails details) {
94+
public final void cancel(OperationContext ctx, OperationCancelDetails details) {
9595
OperationToken token;
9696
try {
9797
token = OperationTokenUtil.loadOperationToken(details.getOperationToken());

0 commit comments

Comments
 (0)