diff --git a/simulator-box-unit/src/test/java/com/equinor/fiberoptics/das/producer/variants/simulatorboxunit/SimulatorBoxUnitTest.java b/simulator-box-unit/src/test/java/com/equinor/fiberoptics/das/producer/variants/simulatorboxunit/SimulatorBoxUnitTest.java index 7ff154a..f27ec48 100644 --- a/simulator-box-unit/src/test/java/com/equinor/fiberoptics/das/producer/variants/simulatorboxunit/SimulatorBoxUnitTest.java +++ b/simulator-box-unit/src/test/java/com/equinor/fiberoptics/das/producer/variants/simulatorboxunit/SimulatorBoxUnitTest.java @@ -43,7 +43,7 @@ import static org.junit.Assert.assertEquals; @ActiveProfiles("test") -@SpringBootTest(classes=SimulatorBoxUnit.class) +@SpringBootTest(classes = SimulatorBoxUnit.class) @RunWith(SpringRunner.class) public class SimulatorBoxUnitTest { @@ -58,7 +58,7 @@ public void testStreamFromSimulatorBox() { AtomicInteger consumed = new AtomicInteger(); Consumer>> logOutput = value -> { - for (PartitionKeyValueEntry entry: value) { + for (PartitionKeyValueEntry entry : value) { DASMeasurement measurement = entry.value; LocalDateTime ldt = Instant.ofEpochMilli(measurement.getStartSnapshotTimeNano() / millisInNano).atZone(ZoneId.systemDefault()).toLocalDateTime(); @@ -72,7 +72,7 @@ public void testStreamFromSimulatorBox() { CountDownLatch latch = new CountDownLatch(1); simulatorBoxUnit.produce() .subscribe(logOutput, - (ex) -> logger.info("Error emitted: " + ex.getMessage()), + (ex) -> logger.info("Error emitted: " + ex.getMessage()), latch::countDown); Helpers.wait(latch); diff --git a/simulator-box-unit/src/test/resources/application-test.yaml b/simulator-box-unit/src/test/resources/application-test.yaml index 039c782..6aa2551 100644 --- a/simulator-box-unit/src/test/resources/application-test.yaml +++ b/simulator-box-unit/src/test/resources/application-test.yaml @@ -3,18 +3,18 @@ das: box: simulator: amplitudeDataType: float - numberOfShots: ${NUMBER_OF_SHOTS:10} - secondsToRun: ${SECONDS_TO_RUN:5} - pulseRate: ${PULSE_RATE:10000} - maxFreq: ${MAX_NYQ_FREQ:5000} - minFreq: ${MIN_NYQ_FREQ:0} + numberOfShots: 10 + secondsToRun: 5 + pulseRate: 10000 + maxFreq: 5000 + minFreq: 0 boxUUID: ${BOX_UUID} opticalPathUUID: ${OPTICAL_PATH_UUID} - spatialSamplingInterval: ${SPATIAL_SAMPLING_INTERVAL:1.1} - pulseWidth: ${PULSE_WIDTH:100.50} - startLocusIndex: ${START_LOCUS_INDEX:0} - disableThrottling: ${DISABLE_THROTTLING:0} - gaugeLength: ${GAUGE_LENGTH:10.209524} - numberOfLoci: ${NUMBER_OF_LOCI:3} + spatialSamplingInterval: 1.1 + pulseWidth: 100.50 + startLocusIndex: 0 + disableThrottling: true + gaugeLength: 10.209524 + numberOfLoci: 3 numberOfPrePopulatedValues: 100 amplitudesPrPackage: 8192 diff --git a/simulator-common/src/main/java/com/equinor/fiberoptics/das/producer/variants/GenericDasProducer.java b/simulator-common/src/main/java/com/equinor/fiberoptics/das/producer/variants/GenericDasProducer.java index bdd67ea..d72bbe9 100644 --- a/simulator-common/src/main/java/com/equinor/fiberoptics/das/producer/variants/GenericDasProducer.java +++ b/simulator-common/src/main/java/com/equinor/fiberoptics/das/producer/variants/GenericDasProducer.java @@ -24,7 +24,6 @@ import reactor.core.publisher.Flux; import java.util.List; -import java.util.function.Consumer; /** * Minimal