public void process()

in connect-audio-stream-solution/kvsMLInferenceFunction/src/main/java/com/amazonaws/kvsmlinference/KVSContactTagProcessor.java [27:45]

• 19 lines of code
• 5 McCabe index (conditional complexity)

    public void process(MkvTag mkvTag, Optional<FragmentMetadata> currentFragmentMetadata) {
        if ("ContactId".equals(mkvTag.getTagName())) {
            if (contactId.equals(mkvTag.getTagValue())) {
                sameContact = true;
            }
            else {
                logger.info("Contact Id in tag does not match expected, will stop streaming. "
                                + "contact id: %s, expected: %s",
                        mkvTag.getTagValue(), contactId);
                sameContact = false;
            }
        }
        if ("STOP_STREAMING".equals(mkvTag.getTagName())) {
            if ("true".equals(mkvTag.getTagValue())) {
                logger.info("STOP_STREAMING tag detected, will stop streaming");
                stopStreaming = true;
            }
        }
    }