async function parseNextFragmentNew()

in Solutions/AWSSCV-VoicemailExpress/Code/awsscv_vmx_kvs_to_s3/awsscv_vmx_kvs_to_s3.js [283:306]

• 23 lines of code
• 1 McCabe index (conditional complexity)

async function parseNextFragmentNew(streamArn, fragmentNumber, contToken) {
    var fragment_paramsData = {
        StartSelector: {
            StartSelectorType: 'FRAGMENT_NUMBER',
            AfterFragmentNumber: fragmentNumber,
        },
        StreamName: streamArn.split('/')[1]
    };

    return new Promise((resolve, reject) => {
        var listener = AWS.EventListeners.Core.HTTP_DATA;
        var request = kinesisvideomedia.getMedia(fragment_paramsData);
        request.removeListener('httpData', listener);
        request.on('httpData', function (chunk, response) {
            decoder.write(chunk);
        });
        request.on('httpDone', function (response) {
            wavOutputStream.write(Buffer.concat(wavBufferArray));
            wavOutputStream.end();
            resolve({});
        });
        request.send();
    });
}