-
Notifications
You must be signed in to change notification settings - Fork 44
Home
Lucas Nelaupe edited this page Aug 22, 2017
·
18 revisions
SwiftQueue built on top of Operation and OperationQueue. Support multiple queues with concurrent run, failure/retry, persistence and more.
SwiftQueue is available on CocoaPod repository.
pod 'SwiftQueue'
In the following example we will create step by step tweet sending that use SwiftQueue to keep tweets ordering.
SwiftQueueManager only requires 1 argument, an array of creator. See Job Creation section.
let tweetQueueManager = SwiftQueueManager(creators: [TweetJobCreator()])
// Type is required to know which implementation of Job we should create
JobBuilder(type: SendTweetJob.type)
// Prevent adding the same job multiple times
.singleInstance(forId: String)
// Different group name will run in parallel
// But one by one for a group
.group(name: "tweet")
// Sending tweet will require internet. At least cellular.
// Will also be executed if connected to wifi.
.internet(atLeast: .cellular)
// Content of your tweet. Can be a class, struct or anything
.with(params: "Hello TweetWorld")
// Retry maximum 5 times if the job fail before removing from the queue
// No retry by default
.retry(max: 5)
// Insert to queue
.schedule(manager: tweetQueueManager)
class SendTweetJob: Job {
public static let type = "SendTweetJob"
private let tweetMessage: String
// Argument specified in JobBuilder.with()
required init(message: String) {
self.tweetMessage = message
}
func onRun(callback: JobResult) throws {
// Actual sending is happening here
API.sendTweet(type: "TEXT", content: tweetMessage)
.onSucess {
// Notify job done without error
callback.onDone(error: nil)
}.onFail { error in
// Job failed.
callback.onDone(error: error)
}
}
func onRetry(error: Error) -> RetryConstraint {
// When a job failed. Since we put retry(max: 5).
// This callback will be called at most 5 times
// Specify if we still want to retry or not.
if error is ApiError {
// No need for retry, Server rejected the message.
// Will remove job from queue even if retry counter > 0
return RetryConstraint.cancel
} else {
// Job will run again. Retry counter will decrease
return RetryConstraint.retry
}
}
func onRemove(error: Error?) {
// Job is removed from queue
// Update your UI or your database
}
}
class TweetJobCreator: JobCreator {
func create(type: String, params: Any?) -> Job? {
// params as specified in JobBuilder.with()
if type == SendTweetJob.type, let message = params as? String {
// Return our actual job.
return SendTweetJob(message: message)
} else {
// Nothing match
return nil
}
}
}