public void process()

in lca-ai-stack/source/kvs_transcribe_streaming/src/main/java/com/amazonaws/kvstranscribestreaming/KVSContactTagProcessor.java [40:58]

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

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