다른 작업을 계속하기 전에 모든 스트림을 강제로 종료하는 방법은 무엇입니까?

Question

node.js 코드를 사용하여 A 저장소에서 이미지를 다운로드 한 다음 B 저장소에 업로드하는 기능을 만듭니다. 다른 작업을 계속하기 전에 모든 스트림을 강제로 완료하려고합니다. 나는이 방법을 시도했지만 성공하지 못했습니다. 예 : 실행하면 getImage이 실행됩니다. getImage이 완료되지 않으면 완료 될 때까지 A-> B-> C를 반복합니다. getImage을 완료합니다. 다른 작업을 계속하기 전에 모든 스트림을 강제로 완료하도록하려면 어떻게해야합니까? 나는 A -> B -> C를 실행하기 전에 getImage을 끝내기를 원한다.

추 신 : pkgCloud를 사용하여 이미지를 IBM Object Storage에 업로드하고 있습니다.

function parseImage(imgUrl){ 
    var loopCondition = true; 
    while(loopCondition){ 
     getImages(imgUrl,imgName); 
     Do task A 
     Do task B 
     Do task C 
    } 
}  

function getImages(imgUrl, imgName) { 
    //Download image from A repository 
    const https = require('https'); 
    var imgSrc; 
    var downloadStream = https.get(imgUrl, function (response) { 

     // Upload image to B repository. 
     var uploadStream = storageClient.upload({container: 'images', remote: imgName}); 
     uploadStream.on('error', function (error) { 
     console.log(error); 
     }); 
     uploadStream.on('success', function (file) { 

     console.log("upload Stream>>>>>>>>>>>>>>>>>Done"); 
     console.log(file.toJSON()); 
     imgSrc = "https://..."; 
     }); 
     response.pipe(uploadStream); 
    }); 
    downloadStream.on('error', function (error) { 
     console.log(error); 
    }); 
    downloadStream.on('finish', function() { 
     console.log("download Stream>>>>>>>>>>>>>>>>>Done"); 
    }); 
    return imgSrc; 
    } 

Answer 1

동기화와 비동기 기능의 차이점을 알고 있어야합니다. getImages 함수는 비동기 코드를 실행하므로이 함수의 결과를 사용하려면 스트리밍이 끝날 때 호출되는 콜백을 전달해야합니다. 다음과 같은 것 :

function parseImage(imgUrl) { 
    getImages(imgUrl, imgName, function (err, imgSrc) { 
     if (imgSrc) { 
     Do task A 
     } else { 
     Do task B 
     } 
    }); 
    } 

    function getImages(imgUrl, imgName, callback) { 
    //Download image from A repository 
    const https = require('https'); 
    var imgSrc; 

    var downloadStream = https.get(imgUrl, function (response) { 
     // Upload image to B repository. 
     var uploadStream = storageClient.upload({ container: 'images', remote: imgName }); 
     uploadStream.on('error', function (error) { 
     console.log(error); 
     return callback(error); 
     }); 

     uploadStream.on('success', function (file) { 
     console.log("upload Stream>>>>>>>>>>>>>>>>>Done"); 
     console.log(file.toJSON()); 
     imgSrc = "https://..."; 

     return callback(null, imgSrc); 
     }); 

     response.pipe(uploadStream); 
    }); 

    downloadStream.on('error', function (error) { 
     console.log(error); 
     return callback(error); 
    }); 

    downloadStream.on('finish', function() { 
     console.log("download Stream>>>>>>>>>>>>>>>>>Done"); 
    }); 
    }