InventoryDataScalingTaskGroup extends AbstractShardingScalingExecutor<InventoryPosition> implements ScalingTask<InventoryPosition> { @Override public SyncProgress getProgress() { InventoryDataSyncTaskProgressGroup result = new InventoryDataSyncTaskProgressGroup(); for (ScalingTask<InventoryPosition> each : scalingTasks) { result.addSyncProgress(each.getProgress()); } return result; } InventoryDataScalingTaskGroup(final Collection<ScalingTask<InventoryPosition>> inventoryDataScalingTasks); @Override void start(); @Override void stop(); @Override SyncProgress getProgress();  }
@Test public void assertGetProgress() { InventoryDataScalingTaskGroup inventoryDataSyncTaskGroup = new InventoryDataScalingTaskGroup(Collections.emptyList()); assertThat(inventoryDataSyncTaskGroup.getProgress(), instanceOf(SyncProgress.class)); }