ios - 轮询异步任务，然后等待1个成功或所有响应被拒绝

PromiseKit版本:4.0

Xcode版本: 8.3.2

我最近开始使用PromiseKit。

实际上，我正在创建一个轮询HTTP请求，该请求的返回结果为“完成”或“未完成”。

我必须在每1秒钟后继续进行HTTP调用，持续5秒钟。

我需要实现的是，如果有1个电话给我完成的状态，我将返回完成(“完成”)。但是，如果我所有的请求都给我一个响应“notCompleted”，那么我需要返回reject(“notCompleted”)

return Promise<T> { fulfilled, reject
let timer1 =  Timer.scheduledTimer(withTimeInterval: TimeInterval(1), repeats: true) { timer in
    pArr.append(Promise<T> { f, r in

        doSomeAsyncTask { T in
            if success {
                f(T)
                fulfilled(T)
                timer.invalidate()
            } else {
                 r(ErrorNotCompleted)
            }
        }

        // timeout option
        _ = after(interval: TimeInterval(15)).then(execute: { () -> Void in
            reject(timeoutForConfirmation)
        })
    })
    }


Timer.scheduledTimer(withTimeInterval: TimeInterval(5), repeats: false) { timer in
    timer1.invalidate()
    timer.invalidate()
    when(resolved: pArr).then { results in
        let count = results.filter({ result -> Bool in
             return result.boolValue
        }).count

        if count == 0 {
            // TODO: then reject here
            reject(ErrorNotCompleted)
        }

        }.catch { error in
            print(error)
    }
}

}
timer1.fire()

如何实现？

是否有更好的方法在PromiseKit中编写以上代码。

最佳答案

这是使用Promises进行基本循环的一种方法...来自我的主旨:https://gist.github.com/dtartaglia/2b19e59beaf480535596

我认为您需要做的就是确保您的 promise 产生者(body)在进行网络调用之前有适当的延迟。

/**
Repeadetly evaluates a promise producer until a value satisfies the predicate.
`promiseWhile` produces a promise with the supplied `producer` and then waits
for it to resolve. If the resolved value satifies the predicate then the
returned promise will fulfill. Otherwise, it will produce a new promise. The
method continues to do this until the predicate is satisfied or an error occurs.
- Returns: A promise that is guaranteed to fulfill with a value that satisfies
the predicate, or reject.
*/

func promiseWhile<T>(pred: (T) -> Bool, body: () -> Promise<T>, fail: (() -> Promise<Void>)? = nil) -> Promise<T> {
    return Promise { fulfill, reject in
        func loop() {
            body().then { (t) -> Void in
                if !pred(t) { fulfill(t) }
                else {
                    if let fail = fail {
                        fail().then { loop() }
                        .error { reject($0) }
                    }
                    else { loop() }
                }
            }
            .error { reject($0) }
        }
        loop()
    }
}

关于ios - 轮询异步任务，然后等待1个成功或所有响应被拒绝，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/44024698/