summaryrefslogtreecommitdiff
path: root/StoneIsland/platforms/ios/Pods/PromisesObjC/Sources/FBLPromises/FBLPromise+Async.m
diff options
context:
space:
mode:
Diffstat (limited to 'StoneIsland/platforms/ios/Pods/PromisesObjC/Sources/FBLPromises/FBLPromise+Async.m')
-rw-r--r--StoneIsland/platforms/ios/Pods/PromisesObjC/Sources/FBLPromises/FBLPromise+Async.m70
1 files changed, 70 insertions, 0 deletions
diff --git a/StoneIsland/platforms/ios/Pods/PromisesObjC/Sources/FBLPromises/FBLPromise+Async.m b/StoneIsland/platforms/ios/Pods/PromisesObjC/Sources/FBLPromises/FBLPromise+Async.m
new file mode 100644
index 00000000..249158ce
--- /dev/null
+++ b/StoneIsland/platforms/ios/Pods/PromisesObjC/Sources/FBLPromises/FBLPromise+Async.m
@@ -0,0 +1,70 @@
+/**
+ 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 "FBLPromise+Async.h"
+
+#import "FBLPromisePrivate.h"
+
+@implementation FBLPromise (AsyncAdditions)
+
++ (instancetype)async:(FBLPromiseAsyncWorkBlock)work {
+ return [self onQueue:self.defaultDispatchQueue async:work];
+}
+
++ (instancetype)onQueue:(dispatch_queue_t)queue async:(FBLPromiseAsyncWorkBlock)work {
+ NSParameterAssert(queue);
+ NSParameterAssert(work);
+
+ FBLPromise *promise = [[FBLPromise alloc] initPending];
+ dispatch_group_async(FBLPromise.dispatchGroup, queue, ^{
+ work(
+ ^(id __nullable value) {
+ if ([value isKindOfClass:[FBLPromise class]]) {
+ [(FBLPromise *)value observeOnQueue:queue
+ fulfill:^(id __nullable value) {
+ [promise fulfill:value];
+ }
+ reject:^(NSError *error) {
+ [promise reject:error];
+ }];
+ } else {
+ [promise fulfill:value];
+ }
+ },
+ ^(NSError *error) {
+ [promise reject:error];
+ });
+ });
+ return promise;
+}
+
+@end
+
+@implementation FBLPromise (DotSyntax_AsyncAdditions)
+
++ (FBLPromise* (^)(FBLPromiseAsyncWorkBlock))async {
+ return ^(FBLPromiseAsyncWorkBlock work) {
+ return [self async:work];
+ };
+}
+
++ (FBLPromise* (^)(dispatch_queue_t, FBLPromiseAsyncWorkBlock))asyncOn {
+ return ^(dispatch_queue_t queue, FBLPromiseAsyncWorkBlock work) {
+ return [self onQueue:queue async:work];
+ };
+}
+
+@end