private PutMediaAckResponseHandler createResponseHandler()

in src/main/java/com/aws/iot/edgeconnectorforkvs/videouploader/VideoUploaderClient.java [324:358]

33 lines of code
5 McCabe index (conditional complexity)


    private PutMediaAckResponseHandler createResponseHandler(CountDownLatch latch,
                                                             @SuppressWarnings("unused") Runnable statusChangedCallBack,
                                                             UploadCallBack uploadCallBack) {
        return new PutMediaAckResponseHandler() {
            @Override
            public void onAckEvent(AckEvent event) {
                log.trace("onAckEvent " + event);
                if (AckEventType.Values.PERSISTED.equals(event.getAckEventType().getEnumValue())) {
                    log.info("Fragment pushed to KVS " + event.getFragmentNumber());
                    if (uploadCallBack != null) {
                        updateUploadCallbackStatus(uploadCallBack, event);
                    }
                }
                if (AckEventType.Values.ERROR.equals(event.getAckEventType().getEnumValue())) {
                    lastKvsStreamingException = new KvsStreamingException(event.toString());
                }
            }

            @Override
            public void onFailure(Throwable t) {
                log.info("onFailure");
                lastKvsStreamingException = new KvsStreamingException(t.getMessage());
                latch.countDown();
            }

            @Override
            public void onComplete() {
                log.info("onComplete");
                if (uploadCallBack != null) {
                    uploadCallBack.onComplete();
                }
                latch.countDown();
            }
        };
    }