Carthage/Checkouts/promises/Sources/Promises/Promise+Retry.swift
// Copyright 2018 Google Inc. All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at:
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
import FBLPromises
/// Creates a pending promise that fulfills with the same value as the promise returned from `work`
/// block, which executes asynchronously on the given `queue`, or rejects with the same error after
/// all retry attempts have been exhausted. On rejection, the `work` block is retried after the
/// given delay `interval` and will continue to retry until the number of specified attempts have
/// been exhausted or will bail early if the given condition is not met.
///
/// - parameters:
/// - queue: A queue to invoke the `work` block on.
/// - count: Max number of retry attempts. The `work` block will be executed once if the specified
/// count is less than or equal to zero. The default is
/// `__FBLPromiseRetryDefaultAttemptsCount`.
/// - interval: Time to wait before the next retry attempt. The default is
/// `__FBLPromiseRetryDefaultDelayInterval`.
/// - predicate: Condition to check before the next retry attempt. The block takes the following
/// parameters:
/// - count: Number of remaining retry attempts.
/// - error: The error the promise was rejected with.
/// - work: A block that executes asynchronously on the given `queue` and returns a value or an
/// error used to resolve the promise.
/// - returns: A new pending promise that fulfills with the same value as the promise returned from
/// `work` block, or rejects with the same error after all retry attempts have been
/// exhausted or if the given condition is not met.
public func retry<Value>(
on queue: DispatchQueue = .promises,
attempts count: Int = __FBLPromiseRetryDefaultAttemptsCount,
delay interval: TimeInterval = __FBLPromiseRetryDefaultDelayInterval,
condition predicate: ((_ count: Int, _ error: Error) -> Bool)? = nil,
_ work: @escaping () throws -> Promise<Value>
) -> Promise<Value> {
#if (swift(>=4.1) || (!swift(>=4.0) && swift(>=3.3)))
let predicateBlock = predicate
#else
var predicateBlock: ((_ count: Int, _ error: Error) -> ObjCBool)?
if predicate != nil {
predicateBlock = { count, error -> ObjCBool in
guard let predicate = predicate else { return true }
return ObjCBool(predicate(count, error))
}
}
#endif // (swift(>=4.1) || (!swift(>=4.0) && swift(>=3.3)))
let objCPromise = Promise<Value>.ObjCPromise<AnyObject>.__onQueue(
queue,
attempts: count,
delay: interval,
condition: predicateBlock
) {
do {
return try work().objCPromise
} catch let error {
return error as NSError
}
}
let promise = Promise<Value>(objCPromise)
// Keep Swift wrapper alive for chained promise until `ObjCPromise` counterpart is resolved.
objCPromise.__pendingObjects?.add(promise)
return promise
}