ReactiveCocoa学习笔记

+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe;

- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock;

- (void)sendNext:(id)value;

// 1. 创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {  
         // 当有订阅者订阅信号，就会调用block。
         task.success = ^(MTANetworkTask *task, id result) {
            [subscriber sendNext:result];
            // 发送信号完成，内部会自动调用[RACDisposable disposable]取消订阅信号。
            [subscriber sendCompleted];
        };
        task.failure = ^(MTANetworkTask *task, NSError *error) {
            [subscriber sendError:[NSError errorWithTask:task error:error]];
        };
// 取消信号信号被取消时机：1.自动取消，当一个信号的订阅者被销毁的时候自动取消订阅，2.手动取消
         // block调用时机：一旦一个信号被取消订阅就会调用；block作用：当信号被取消时清空资源
         return [RACDisposable disposableWithBlock:^{  
                // block调用时机：当信号发送完成或者发送错误，就会自动执行这个block,取消订阅信号。
                NSLog(@"取消订阅");  
         }]; 
}]; 

 // 2. 订阅信号 
RACDisposable *disposable = [signal subscribeNext:^(id x) {     
        // block调用时刻：每当有信号发出数据，就会调用block.  
         if ([x boolValue]) {
            _navView.hidden = YES;
        } else {
           _navView.hidden = NO;
          [UIView animateWithDuration:.5  animations:^{_navView.alpha = 1; }];
        } 
 }];  
// 3. 取消订阅  
 [disposable dispose];  

// RACObserve(self, username) creates a new RACSignal that sends the current
// value of self.username, then the new value whenever it changes.
// -subscribeNext: will execute the block whenever the signal sends a value.
[RACObserve(self, username) subscribeNext:^(NSString *newName) {
    NSLog(@"%@", newName);
}];

// Only logs names that starts with "j".
//
// -filter returns a new RACSignal that only sends a new value when its block returns YES.
[[RACObserve(self, username)
    filter:^(NSString *newName) {
        return [newName hasPrefix:@"j"];
    }]
    subscribeNext:^(NSString *newName) {
        NSLog(@"%@", newName);
    }];

// RAC() is a macro that makes the binding look nicer.
// 
// +combineLatest:reduce: takes an array of signals, executes the block with the
// latest value from each signal whenever any of them changes, and returns a new
// RACSignal that sends the return value of that block as values.

RAC(self, createEnabled) = [RACSignal  combineLatest:@[ RACObserve(self, password), RACObserve(self, passwordConfirmation) ] 
    reduce:^(NSString *password, NSString *passwordConfirm) {
        return @([passwordConfirm isEqualToString:password]);
    }];

//所有的接口处理完，再刷新
     RACSignal *performanceSingal = [RACObserve(self.viewModel, requestPerformanceFinished) distinctUntilChanged];
     RACSignal *liveDSignal = [RACObserve(self.viewModel,requestLiveDataFinished) distinctUntilChanged];
     RACSignal *needTodoSingal = [RACObserve(self.viewModel, requestNeedTodoFinished) distinctUntilChanged];
     RACSignal *quickOfficeSingal = [RACObserve(self.viewModel, requestQuickOfficeFinished) distinctUntilChanged];
    
    [[[RACSignal combineLatest:@[performanceSingal,liveDSignal,needTodoSingal,quickOfficeSingal]
                        reduce:^id(NSNumber *requestPerformanceFinished,NSNumber *requestLiveFinished,NSNumber *requestNeedTodoFinished,NSNumber *requestQuickOfficeFinished){
                            BOOL requestFinished = ([requestPerformanceFinished boolValue]
                                                    && [requestLiveFinished boolValue]
                                                    && [requestNeedTodoFinished boolValue]
                                                    && [requestQuickOfficeFinished boolValue]);
                            return @(requestFinished);
                        }] distinctUntilChanged]
     subscribeNext:^(NSNumber *finishedNumber) {
         @strongify(self);
         if([finishedNumber boolValue]){
             [self setShowLoading:NO];
             [self.tableView reloadData];
             [self refreshFinished];
         }
     }];

// -rac_command is an addition to UIButton. The button will send itself on that
// command whenever it‘s pressed.
self.button.rac_command = [[RACCommand alloc] initWithSignalBlock:^(id input) {
    NSLog(@"button was pressed!");
    return [RACSignal empty];
}];

// Performs NSLog() when they are both completed.
//
// +merge: takes an array of signals and returns a new RACSignal that passes
// through the values of all of the signals and completes when all of the
// signals complete.
//
// -subscribeCompleted: will execute the block when the signal completes.

[[RACSignal  merge:@[ [client fetchUserRepos], [client fetchOrgRepos] ]] 
    subscribeCompleted:^{
        NSLog(@"They‘re both done!");
    }];