我目前正在编写执行以下操作的代码:

1. 向开始将数据库压缩为 .zip 文件的 Web 服务发送请求
2. 反复调用网络服务函数来检查数据库是否已经压缩并准备好下载
3. 使用 NSURLSessionDownloadTask 下载数据库
4. 解压缩文件并将其存储到文档目录
5. 将解压缩的文件重命名为所需的名称

除此之外，整个过程负责使用回调(即闭包)进行错误处理。

目前代码如下:

func continueByRepeatedlyCheckingDatabaseZipReady() -> Void {
    let conditionClosure : ((x : String) -> Bool) = {x in x == "OK"}
    let repetitionClosure : ((x : String) -> String) = {result in String(result)}

    RequestTask(method: DatabaseZipReady()).apply(5, c: conditionClosure, f:repetitionClosure,
        onSuccess: {success in
            self.startDownloadDatabase()
        }, onFailure: {error in
            self.failure(error: error)
    })
} 

func startDownloadDatabase() -> Void {
    let databaseSourceURL : NSURL = RequestDatabaseURLForDownload().requestURL

    DownloadTask(url: databaseSourceURL,
        progressCallback: {received, total in

        }, successCallback: {location in
            self.unzippingDatabaseFile(location)
        }, failureCallback: {error in
            self.failure(error: error)
    }).resume()
}

func unzippingDatabaseFile(location : NSURL) {

    UnZip(sourceURL: location, destinationURL: FileManagement().documentsDirectory()).execute({
            self.renameDatabaseNameIntoCRMDB()
            self.deleteTemporalyDatabaseFileOnTheServer()
        }, onFailure: {error in
            self.failure(error: error)
    })
}

等等……

但是，我想要避免的(为了代码的可测试性和简单性)是拥有这样的函数管道。作为第一步，我查看了 GoF 并试图找到适合该问题的模式。但是，不幸的是，他们都不适合这个问题。

因此，有没有人对如何打破这些功能(即行为)之间的依赖关系有很好的建议？另请记住，我正在努力让我的代码尽可能地发挥作用。

最佳答案

一些观察结果。

1. 您可以从这些方法中删除调用流程中下一步的代码，并更改这些方法以获取完成处理程序。然后，调用这些方法的代码将触发下一步。

   func continueByRepeatedlyCheckingDatabaseZipReady(completionHandler: (Bool)->()) -> Void {
       let conditionClosure : ((x : String) -> Bool) = {x in x == "OK"}
       let repetitionClosure : ((x : String) -> String) = {result in String(result)}
   
       RequestTask(method: DatabaseZipReady()).apply(5, c: conditionClosure, f:repetitionClosure,
           onSuccess: {success in
               completionHandler(success)
           }, onFailure: {error in
               self.failure(error: error)
       })
   }
   
   func startDownloadDatabase(completionHandler: (NSURL)->()) -> Void {
       let databaseSourceURL : NSURL = RequestDatabaseURLForDownload().requestURL
   
       DownloadTask(url: databaseSourceURL,
           progressCallback: {received, total in
   
           }, successCallback: {location in
               completionHandler(location)
           }, failureCallback: {error in
               self.failure(error: error)
       }).resume()
   }
   
   func unzippingDatabaseFile(location : NSURL, completionHandler: ()->()) {
       UnZip(sourceURL: location, destinationURL: FileManagement().documentsDirectory()).execute({
               completionHandler()
           }, onFailure: {error in
               self.failure(error: error)
       })
   }
   

   通过提取确定下一步的代码，您可以对这些方法进行单元测试，而不会产生依赖关系，也无需进行任何 stub 。

2. 关于如何启动流程中的下一步，您可以在前一个步骤的完成处理程序中调用每个步骤:

   func runWholeProcess() {
       continueByRepeatedlyCheckingDatabaseZipReady() { success in
           self.startDownloadDatabase() { location in
               self.unzippingDatabaseFile(location) {
                   self.renameDatabaseNameIntoCRMDB()
                   self.deleteTemporalyDatabaseFileOnTheServer()
               }
           }
       }
   }
   

3. 如果您不喜欢这种嵌套，有很多方法可以在异步任务之间建立依赖关系。

   • 例如，您可以将它们包装在异步 NSOperation 子类对象中，然后您可以使用它们之间的依赖关系。

   • 或者，如果您可以使用第三方库，则可以使用 promises/futures 库(例如 PromiseKit、BrightFutures 或 RXPromise)，您可以在其中链接一系列异步任务一起。我对 Swift 中的 promises/futures 感到矛盾:我喜欢这个想法，但我对这些库持谨慎态度，因为它们之间存在不一致，缺乏对 Swift 中 futures/promises 的广泛接受，等等。但我为了完整起见，请提及它。

我必须承认，出于各种原因，我不喜欢在这些不同的方法中依赖 self.failure。我可能会在成功或失败时调用我的完成 block ，传递相关信息，然后退出 self.failure。您要确保这些方法不依赖于类的任何属性，而只是传递彼此需要的相关信息。

关于swift - 如何避免函数流水线？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35245163/