RACImmediateScheduler.m 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. //
  2. // RACImmediateScheduler.m
  3. // ReactiveObjC
  4. //
  5. // Created by Josh Abernathy on 11/30/12.
  6. // Copyright (c) 2012 GitHub, Inc. All rights reserved.
  7. //
  8. #import "RACImmediateScheduler.h"
  9. #import "RACScheduler+Private.h"
  10. @implementation RACImmediateScheduler
  11. #pragma mark Lifecycle
  12. - (instancetype)init {
  13. return [super initWithName:@"org.reactivecocoa.ReactiveObjC.RACScheduler.immediateScheduler"];
  14. }
  15. #pragma mark RACScheduler
  16. - (RACDisposable *)schedule:(void (^)(void))block {
  17. NSCParameterAssert(block != NULL);
  18. block();
  19. return nil;
  20. }
  21. - (RACDisposable *)after:(NSDate *)date schedule:(void (^)(void))block {
  22. NSCParameterAssert(date != nil);
  23. NSCParameterAssert(block != NULL);
  24. [NSThread sleepUntilDate:date];
  25. block();
  26. return nil;
  27. }
  28. - (RACDisposable *)after:(NSDate *)date repeatingEvery:(NSTimeInterval)interval withLeeway:(NSTimeInterval)leeway schedule:(void (^)(void))block {
  29. NSCAssert(NO, @"+[RACScheduler immediateScheduler] does not support %@.", NSStringFromSelector(_cmd));
  30. return nil;
  31. }
  32. - (RACDisposable *)scheduleRecursiveBlock:(RACSchedulerRecursiveBlock)recursiveBlock {
  33. for (__block NSUInteger remaining = 1; remaining > 0; remaining--) {
  34. recursiveBlock(^{
  35. remaining++;
  36. });
  37. }
  38. return nil;
  39. }
  40. @end