import java.util.List;
import java.util.Map;
import java.util.Optional;
-import java.util.concurrent.ExecutionException;
import java.util.stream.Collectors;
@RequiredArgsConstructor
public class DriverController
{
- private final EndlessConsumer consumer;
private final ApplicationRecordHandler recordHandler;
private final AdderResults results;
- @PostMapping("start")
- public void start()
- {
- consumer.start();
- }
-
- @PostMapping("stop")
- public void stop() throws ExecutionException, InterruptedException
- {
- consumer.stop();
- }
-
-
@GetMapping("state")
public Map<Integer, Map<String, AdderResult>> state()
{