Spring/spring-statemachine
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add Flux test for denied result

Browse Source 
- Relates #802
This commit is contained in:
Janne Valkealahti
2019-12-26 12:41:24 +00:00
parent dd2017c8b5
commit 9e0bdae46f
1 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
spring-statemachine-core/src/test/java/org/springframework/statemachine/ReactiveTests.java
View File

@@ -137,6 +137,27 @@ public class ReactiveTests extends AbstractStateMachineTests {
.verify();
}
@SuppressWarnings("unchecked")
@Test
public void testFluxsSomeDenied() {
context.register(Config1.class);
context.refresh();
assertThat(context.containsBean(StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE)).isTrue();
StateMachine<TestStates,TestEvents> machine =
context.getBean(StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE, StateMachine.class);
assertThat(machine).isNotNull();
verifyStart(machine);
assertThat(machine.getState().getIds()).containsExactlyInAnyOrder(TestStates.S1);
StepVerifier.create(machine.sendEvents(asFlux(TestEvents.E1, TestEvents.E2, TestEvents.E3)))
.expectNextMatches(r -> r.getResultType() == ResultType.ACCEPTED)
.expectNextMatches(r -> r.getResultType() == ResultType.ACCEPTED)
.expectNextMatches(r -> r.getResultType() == ResultType.DENIED)
.expectComplete()
.verify();
assertThat(machine.getState().getIds()).containsExactlyInAnyOrder(TestStates.S3);
}
@Test
@SuppressWarnings("unchecked")
public void testJoin() throws Exception {