private void putEndTasksSignal()

in S3HtsjdkPlugin/src/main/java/com/epam/cmbi/s3/parallel/ParallelPartsLoader.java [127:135]

• 8 lines of code
• 2 McCabe index (conditional complexity)

    private void putEndTasksSignal() throws InterruptedException {
        if (!canceledFlag.get()) {
            //poisoned task, to show that no more tasks shell be presented
            tasksQueue.put(threadPool.submit(() -> {
                LOG.debug("future poison");
                return Optional.empty();
            }));
        }
    }