runningTest.stopStressors();
slaveState.remove(RunningTest.nameFor(testName));
slaveState.removeServiceListener(runningTest);
}
destroy();
<BUG>if (statistics != null && mergeThreadStats) {
Statistics merged = null;
for (Statistics s : statistics) {
if (merged == null) merged = s.copy();
else merged.merge(s);
}</BUG>
return newStatisticsAck(Collections.singletonList(merged), failed);

runningTest.stopStressors();
slaveState.remove(RunningTest.nameFor(testName));
slaveState.removeServiceListener(runningTest);
}
destroy();
if (statistics != null && mergeThreadStats) {
Statistics merged = statistics.stream().reduce(Statistics.MERGE).orElse(null);
return newStatisticsAck(Collections.singletonList(merged), failed);
