File tree Expand file tree Collapse file tree
temporal-sdk/src/test/java/io/temporal/client/nexus Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11package io .temporal .client .nexus ;
22
3- import static org .junit .Assume .assumeTrue ;
4-
53import io .temporal .api .nexus .v1 .Endpoint ;
64import io .temporal .client .NexusClient ;
75import io .temporal .client .NexusClientOptions ;
1412import io .temporal .client .UntypedNexusServiceClient ;
1513import io .temporal .testing .internal .SDKTestWorkflowRule ;
1614import io .temporal .workflow .shared .EchoNexusServiceImpl ;
15+ import io .temporal .workflow .shared .StandaloneNexusTestPrerequisites ;
1716import io .temporal .workflow .shared .TestNexusServices ;
1817import io .temporal .workflow .shared .TestWorkflows ;
1918import java .time .Duration ;
@@ -44,11 +43,8 @@ public class NexusAsyncApiTest {
4443 .build ();
4544
4645 @ BeforeClass
47- public static void requireExternalService () {
48- // The time-skipping test server does not implement standalone Nexus operation RPCs.
49- assumeTrue (
50- "standalone Nexus operations require a real server" ,
51- SDKTestWorkflowRule .useExternalService );
46+ public static void requireServerWithStandaloneNexusSupport () {
47+ StandaloneNexusTestPrerequisites .requireServerSupport ();
5248 }
5349
5450 // --- NexusServiceClient.executeAsync ---
Original file line number Diff line number Diff line change 11package io .temporal .client .nexus ;
22
3- import static org .junit .Assume .assumeTrue ;
4-
53import io .temporal .api .nexus .v1 .Endpoint ;
64import io .temporal .client .NexusClient ;
75import io .temporal .client .NexusOperationExecutionCount ;
119import io .temporal .client .UntypedNexusServiceClient ;
1210import io .temporal .testing .internal .SDKTestWorkflowRule ;
1311import io .temporal .workflow .shared .EchoNexusServiceImpl ;
12+ import io .temporal .workflow .shared .StandaloneNexusTestPrerequisites ;
1413import io .temporal .workflow .shared .TestNexusServices ;
1514import io .temporal .workflow .shared .TestWorkflows ;
1615import java .time .Duration ;
@@ -33,11 +32,8 @@ public class NexusClientTest {
3332 .build ();
3433
3534 @ BeforeClass
36- public static void requireExternalService () {
37- // The time-skipping test server does not implement standalone Nexus operation RPCs.
38- assumeTrue (
39- "standalone Nexus operations require a real server" ,
40- SDKTestWorkflowRule .useExternalService );
35+ public static void requireServerWithStandaloneNexusSupport () {
36+ StandaloneNexusTestPrerequisites .requireServerSupport ();
4137 }
4238
4339 @ Test
Original file line number Diff line number Diff line change 11package io .temporal .client .nexus ;
22
3- import static org .junit .Assume .assumeTrue ;
4-
53import io .temporal .api .enums .v1 .NexusOperationExecutionStatus ;
64import io .temporal .api .nexus .v1 .Endpoint ;
75import io .temporal .client .NexusClient ;
1513import io .temporal .client .UntypedNexusServiceClient ;
1614import io .temporal .testing .internal .SDKTestWorkflowRule ;
1715import io .temporal .workflow .shared .EchoNexusServiceImpl ;
16+ import io .temporal .workflow .shared .StandaloneNexusTestPrerequisites ;
1817import io .temporal .workflow .shared .TestNexusServices ;
1918import io .temporal .workflow .shared .TestWorkflows ;
2019import java .time .Duration ;
@@ -39,11 +38,8 @@ public class NexusOperationHandleTest {
3938 .build ();
4039
4140 @ BeforeClass
42- public static void requireExternalService () {
43- // The time-skipping test server does not implement standalone Nexus operation RPCs.
44- assumeTrue (
45- "standalone Nexus operations require a real server" ,
46- SDKTestWorkflowRule .useExternalService );
41+ public static void requireServerWithStandaloneNexusSupport () {
42+ StandaloneNexusTestPrerequisites .requireServerSupport ();
4743 }
4844
4945 @ Test
Original file line number Diff line number Diff line change 11package io .temporal .client .nexus ;
22
3- import static org .junit .Assume .assumeTrue ;
4-
53import io .temporal .api .nexus .v1 .Endpoint ;
64import io .temporal .client .NexusClientOptions ;
75import io .temporal .client .NexusOperationExecutionDescription ;
119import io .temporal .client .UntypedNexusOperationHandle ;
1210import io .temporal .testing .internal .SDKTestWorkflowRule ;
1311import io .temporal .workflow .shared .EchoNexusServiceImpl ;
12+ import io .temporal .workflow .shared .StandaloneNexusTestPrerequisites ;
1413import io .temporal .workflow .shared .TestNexusServices ;
1514import io .temporal .workflow .shared .TestWorkflows ;
1615import java .time .Duration ;
@@ -34,11 +33,8 @@ public class NexusServiceClientTest {
3433 .build ();
3534
3635 @ BeforeClass
37- public static void requireExternalService () {
38- // The time-skipping test server does not implement standalone Nexus operation RPCs.
39- assumeTrue (
40- "standalone Nexus operations require a real server" ,
41- SDKTestWorkflowRule .useExternalService );
36+ public static void requireServerWithStandaloneNexusSupport () {
37+ StandaloneNexusTestPrerequisites .requireServerSupport ();
4238 }
4339
4440 @ Test
You can’t perform that action at this time.
0 commit comments