This repository has been archived by the owner on Feb 28, 2020. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
16 changed files
with
678 additions
and
602 deletions.
There are no files selected for viewing
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,127 @@ | ||
| // | ||
| // AsyncAwait.swift | ||
| // AlecrimAsyncKit | ||
| // | ||
| // Created by Vanderlei Martinelli on 2015-05-10. | ||
| // Copyright (c) 2015 Alecrim. All rights reserved. | ||
| // | ||
|
|
||
| import Foundation | ||
|
|
||
| private let _defaultTaskQueue: NSOperationQueue = { | ||
| let queue = NSOperationQueue() | ||
| queue.name = "com.alecrim.AlecrimAsyncKit.Task" | ||
| queue.qualityOfService = .Default | ||
| queue.maxConcurrentOperationCount = NSOperationQueueDefaultMaxConcurrentOperationCount | ||
|
|
||
| return queue | ||
| }() | ||
|
|
||
| // MARK: - | ||
|
|
||
| public typealias TaskPriority = NSOperationQueuePriority | ||
|
|
||
| // MARK: - async | ||
|
|
||
| @warn_unused_result | ||
| public func async<V>(queue: NSOperationQueue = _defaultTaskQueue, qualityOfService: NSQualityOfService? = nil, observers: [TaskObserver]? = nil, closure: () -> V) -> NonFailableTask<V> { | ||
| return asyncEx(queue, qualityOfService: qualityOfService, observers: observers) { task in | ||
| let value = closure() | ||
| task.finishWithValue(value) | ||
| } | ||
| } | ||
|
|
||
| @warn_unused_result | ||
| public func async<V>(queue: NSOperationQueue = _defaultTaskQueue, qualityOfService: NSQualityOfService? = nil, condition: TaskCondition, observers: [TaskObserver]? = nil, closure: () throws -> V) -> Task<V> { | ||
| return async(queue, qualityOfService: qualityOfService, conditions: [condition], observers: observers, closure: closure) | ||
| } | ||
|
|
||
| @warn_unused_result | ||
| public func async<V>(queue: NSOperationQueue = _defaultTaskQueue, qualityOfService: NSQualityOfService? = nil, conditions: [TaskCondition]? = nil, observers: [TaskObserver]? = nil, closure: () throws -> V) -> Task<V> { | ||
| return asyncEx(queue, qualityOfService: qualityOfService, observers: observers) { task in | ||
| do { | ||
| let value = try closure() | ||
| task.finishWithValue(value) | ||
| } | ||
| catch let error { | ||
| task.finishWithError(error) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| // MARK: - asyncEx | ||
|
|
||
| @warn_unused_result | ||
| public func asyncEx<V>(queue: NSOperationQueue = _defaultTaskQueue, qualityOfService: NSQualityOfService? = nil, taskPriority: TaskPriority? = nil, observers: [TaskObserver]? = nil, closure: (NonFailableTask<V>) -> Void) -> NonFailableTask<V> { | ||
| return taskWithQueue(queue, qualityOfService: qualityOfService, taskPriority: taskPriority, conditions: nil, observers: observers, closure: closure) | ||
| } | ||
|
|
||
| @warn_unused_result | ||
| public func asyncEx<V>(queue: NSOperationQueue = _defaultTaskQueue, qualityOfService: NSQualityOfService? = nil, taskPriority: TaskPriority? = nil, condition: TaskCondition, observers: [TaskObserver]? = nil, closure: (Task<V>) -> Void) -> Task<V> { | ||
| return asyncEx(queue, qualityOfService: qualityOfService, taskPriority: taskPriority, conditions: [condition], observers: observers, closure: closure) | ||
| } | ||
|
|
||
|
|
||
| @warn_unused_result | ||
| public func asyncEx<V>(queue: NSOperationQueue = _defaultTaskQueue, qualityOfService: NSQualityOfService? = nil, taskPriority: TaskPriority? = nil, conditions: [TaskCondition]? = nil, observers: [TaskObserver]? = nil, closure: (Task<V>) -> Void) -> Task<V> { | ||
| return taskWithQueue(queue, qualityOfService: qualityOfService, taskPriority: taskPriority, conditions: conditions, observers: observers, closure: closure) | ||
| } | ||
|
|
||
|
|
||
| // MARK: - await | ||
|
|
||
| public func await<V>(@noescape closure: () -> NonFailableTask<V>) -> V { | ||
| let task = closure() | ||
| return await(task) | ||
| } | ||
|
|
||
| public func await<V>(task: NonFailableTask<V>) -> V { | ||
| task.waitUntilFinished() | ||
| return task.value | ||
| } | ||
|
|
||
| public func await<V>(@noescape closure: () -> Task<V>) throws -> V { | ||
| let task = closure() | ||
| return try await(task) | ||
| } | ||
|
|
||
| public func await<V>(task: Task<V>) throws -> V { | ||
| task.waitUntilFinished() | ||
|
|
||
| if let error = task.error { | ||
| throw error | ||
| } | ||
|
|
||
| return task.value | ||
| } | ||
|
|
||
|
|
||
| // MARK: - | ||
|
|
||
| private func taskWithQueue<T: InitializableTaskType>(queue: NSOperationQueue, qualityOfService: NSQualityOfService?, taskPriority: TaskPriority?, conditions: [TaskCondition]?, observers: [TaskObserver]?, closure: (T) -> Void) -> T { | ||
| assert(queue.maxConcurrentOperationCount == NSOperationQueueDefaultMaxConcurrentOperationCount || queue.maxConcurrentOperationCount > 1, "Task `queue` cannot be the main queue nor a serial queue.") | ||
|
|
||
| // | ||
| let task = T(conditions: conditions, observers: observers, closure: closure) | ||
|
|
||
| // | ||
| if let operation = task as? TaskOperation { | ||
| if let qualityOfService = qualityOfService { | ||
| operation.qualityOfService = qualityOfService | ||
| } | ||
|
|
||
| if let taskPriority = taskPriority { | ||
| operation.queuePriority = taskPriority | ||
| } | ||
|
|
||
| // | ||
| operation.willEnqueue() | ||
| queue.addOperation(operation) | ||
| } | ||
| else { | ||
| fatalError() | ||
| } | ||
|
|
||
| // | ||
| return task | ||
| } |
Oops, something went wrong.