Skip to content

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
jbfbell committed Jan 3, 2024
1 parent 7e896e5 commit 3bfed90
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,9 @@ public void testUpdateTimeAndIncreaseInterval(final boolean enableIncrementalTyp
initializeDestinationConfigOption(enableIncrementalTypingAndDeduping);
final var valve = new TypeAndDedupeOperationValve(minuteUpdates);
valve.addStream(STREAM_A);
IntStream.range(0, 1).forEach(__ -> Assertions.assertEquals(valve.readyToTypeAndDedupe(STREAM_A), enableIncrementalTypingAndDeduping)); // start ready to T&D
IntStream.range(0, 1).forEach(__ -> Assertions.assertEquals(valve.readyToTypeAndDedupe(STREAM_A), enableIncrementalTypingAndDeduping)); // start
// ready
// to T&D
Assertions.assertEquals(valve.readyToTypeAndDedupe(STREAM_A), enableIncrementalTypingAndDeduping);
valve.updateTimeAndIncreaseInterval(STREAM_A);
IntStream.range(0, 360).forEach(__ -> Assertions.assertFalse(valve.readyToTypeAndDedupe(STREAM_A)));
Expand Down

0 comments on commit 3bfed90

Please sign in to comment.