Promise＆遞歸，如何處理沒有回調的找到的項目？

Question

我在服務器上有一個文件夾層次結構。我想循環遍歷這個層次，並且遞歸地，當找到一個文件時，調用一個自定義方法。

現在，我的代碼看起來是這樣的：

searchFile(root, handleFile); 

// loop over all folders recursively, then handle files 
function searchFile(item, callbackWhenFile) { 
    if (itIsFolder(item)) { 
     $http.get("api.call.com/children/" + item.id) 
       .then(function (children) { 
        angular.forEach(children, 
         function (child) { 
          searchFile(child, callbackWhenFile); 
         }); 
       }); 
    } 
    else { 
     // this is not a folder, so this is a file 
     callbackWhenFile(item); 
    } 
} 

回調是用來代替承諾的事實是不是一件好事。

但我試圖找到一種方法，使它與承諾一起工作，沒有機會。

在一個理想的解決方案，我想這樣做：

searchFile(root).then(function (file) { 
    handleFile(file) 
}); 

我看着q.all $，$ q.when，但似乎沒有適應這種情況。我們不知道我們將要使用的文件數量，這使得問題變得困難。

任何人都有一個想法如何解決這個問題？

編輯答案

Promises are not the way to go.

隨着RxJS和觀察對象，這可以寫成：

getFileStream(root).subscribe(function (file) { 
    handleFile(file); 
}); 

function getFileStream(root) { 
    var source = Rx.Observable.create(function (observer) { 
     observeFiles(observer, root); 
    }); 
    return source; 
} 

function observeFiles(observer, item) { 
    if (itIsFolder(item)) { 
     $http.get("api.call.com/children/" + item.id) 
       .then(function (children) { 
        angular.forEach(children, 
         function (child) { 
          searchFile(observer, child); 
         }); 
       }); 
    } 
    else { 
     observer.onNext(item); 
    } 
} 

Answer 1

一個承諾只能解析到一個值。該值可以是一個對象，也可以是一個數組，但最終它是一個單一值 - 不是流。

您的「理想解決方案」被定義爲它確實生成了一個流，這是不可能的。

您可以：

1. 留下你的代碼，因爲它是。您的回調被異步調用，並且只要有文件需要處理即可。
2. 更改您的遞歸來組裝單個值。一個平面數組/地圖（對象...）的文件。該值可以在下一個函數（.then(processArray)）內同步處理。
3. 使用像BaconJS或RxJS流媒體庫。

Answer 2

下面的代碼應該做的伎倆：

searchFile(root).then(function (files) { 
    function (files) { 
     angular.forEach(files, 
         function (file) { 
          handleFile(file); 
         }); 
    }); 
}); 

// loop over all folders recursively, then handle files 
function searchFile(item) { 
    var deferred = $q.defer(); 
    var files = []; 
    if (itIsFolder(item)) { 
     $http.get("api.call.com/children/" + item.id) 
       .then(function (children) { 
        angular.forEach(children, 
         function (child) { 
          searchFile(child).then(
           function (files) { 
            angular.forEach(files, 
            function (file) { 
             files.add(file); 
            }); 
           }); 
         }); 

         deferred.resolve(files); 
       }); 
    } 
    else { 
     files.add(item); 
     deferred.resolve(files); 
    } 

    return deferred.promise; 
}