Skip to content

Commit

Permalink
Create Temporal Subset Simulation Tests
Browse files Browse the repository at this point in the history
* Promoted AnchorTestModel to package-private
  • Loading branch information
Mythicaeda committed Mar 13, 2023
1 parent 26d14cc commit b7ee375
Show file tree
Hide file tree
Showing 2 changed files with 966 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -486,7 +486,7 @@ public final class AnchorsSimulationDriverTests {
private static void assertEqualsSimulationResults(SimulationResults expected, SimulationResults actual){
assertEquals(expected.startTime, actual.startTime);
assertEquals(expected.duration, actual.duration);
assertEquals(expected.simulatedActivities.entrySet().size(), actual.simulatedActivities.size());
assertEquals(expected.simulatedActivities.size(), actual.simulatedActivities.size());
for(final var entry : expected.simulatedActivities.entrySet()){
final var key = entry.getKey();
final var expectedValue = entry.getValue();
Expand Down Expand Up @@ -1057,15 +1057,15 @@ public void naryTreeAnchorChain() {
}

//region Mission Model
private static final List<Triple<Integer, String, ValueSchema>> modelTopicList = Arrays.asList(
/* package-private */static final List<Triple<Integer, String, ValueSchema>> modelTopicList = Arrays.asList(
Triple.of(0, "ActivityType.Input.DelayActivityDirective", new ValueSchema.StructSchema(Map.of())),
Triple.of(1, "ActivityType.Output.DelayActivityDirective", new ValueSchema.StructSchema(Map.of())),
Triple.of(2, "ActivityType.Input.DecomposingActivityDirective", new ValueSchema.StructSchema(Map.of())),
Triple.of(3, "ActivityType.Output.DecomposingActivityDirective", new ValueSchema.StructSchema(Map.of())));

private static final Topic<Object> delayedActivityDirectiveInputTopic = new Topic<>();
private static final Topic<Object> delayedActivityDirectiveOutputTopic = new Topic<>();
private static final DirectiveType<Object, Object, Object> delayedActivityDirective = new DirectiveType<>() {
/* package-private*/ static final DirectiveType<Object, Object, Object> delayedActivityDirective = new DirectiveType<>() {
@Override
public InputType<Object> getInputType() {
return testModelInputType;
Expand All @@ -1090,7 +1090,7 @@ public TaskFactory<Object> getTaskFactory(final Object o, final Object o2) {

private static final Topic<Object> decomposingActivityDirectiveInputTopic = new Topic<>();
private static final Topic<Object> decomposingActivityDirectiveOutputTopic = new Topic<>();
private static final DirectiveType<Object, Object, Object> decomposingActivityDirective = new DirectiveType<>() {
/* package-private */ static final DirectiveType<Object, Object, Object> decomposingActivityDirective = new DirectiveType<>() {
@Override
public InputType<Object> getInputType() {
return testModelInputType;
Expand Down Expand Up @@ -1169,7 +1169,7 @@ public SerializedValue serialize(final Object value) {
}
};

private static final MissionModel<Object> AnchorTestModel = new MissionModel<>(
/* package-private */ static final MissionModel<Object> AnchorTestModel = new MissionModel<>(
new Object(),
new LiveCells(null),
Map.of(),
Expand Down
Loading

0 comments on commit b7ee375

Please sign in to comment.