ReactiveCocoa是響應(yīng)式編程(FRP)在iOS中的一個(gè)實(shí)現(xiàn)框架。

監(jiān)聽對(duì)象的成員變量變化

這種情況其實(shí)就是ios KVO機(jī)制使用的場(chǎng)景，使用KVO實(shí)現(xiàn)，通常有三個(gè)步驟：1，給對(duì)象的成員變量添加監(jiān)聽；2，實(shí)現(xiàn)監(jiān)聽回調(diào)；3，取消監(jiān)聽；而通過(guò)RAC可以直接實(shí)現(xiàn)，RAC的回調(diào)是通過(guò)block實(shí)現(xiàn)的，類似于過(guò)程式編程，上下文也更容易理解一些。

信號(hào)

作為一個(gè)iOS開發(fā)者，你寫的每一行代碼幾乎都是在相應(yīng)某個(gè)事件，例如按鈕的點(diǎn)擊，收到網(wǎng)絡(luò)消息，屬性的變化（通過(guò)KVO）或者用戶位置的變化（通過(guò)CoreLocation）。但是這些事件都用不同的方式來(lái)處理，比如action、delegate、KVO、callback等。ReactiveCocoa為事件定義了一個(gè)標(biāo)準(zhǔn)接口，從而可以使用一些基本工具來(lái)更容易的連接、過(guò)濾和組合。
RAC為應(yīng)用中發(fā)生的不同事件流提供了一個(gè)標(biāo)準(zhǔn)接口。在ReactiveCocoa術(shù)語(yǔ)中這個(gè)叫做信號(hào)（signal），由RACSignal類表示。

RACSignal

RAC中的基本類型。各個(gè)方法操作的都是RACSignal這種信號(hào)類型，而這種信號(hào)類型中可以封裝各種Object類型。

• 控件的信號(hào)

//textField
RACSignal *usernameSourceSignal =
    self.usernameTextField.rac_textSignal;
//button
RACSignal *buttonSignal = [self.addButton rac_signalForControlEvents:UIControlEventTouchUpInside];

• RAC方法的返回值

RACSignal *filteredUsername =[usernameSourceSignal
  filter:^BOOL(id value){
    NSString*text = value;
    return text.length > 3;
  }];

簡(jiǎn)單監(jiān)聽單一變量

RACObserve與subscribeNext

使用RACObserve來(lái)監(jiān)聽變量，產(chǎn)生信號(hào)，使用subscribeNext訂閱該信號(hào)，對(duì)其進(jìn)行回調(diào)處理。

注意：是最后一步的回調(diào)處理，所以不再返回信號(hào)，也不能后續(xù)對(duì)信號(hào)進(jìn)行操作處理。

• 場(chǎng)景：當(dāng)前類有一個(gè)成員變量 NSString *input，當(dāng)它的值被改變時(shí)，發(fā)送一個(gè)請(qǐng)求。
  實(shí)現(xiàn)：

[RACObserve(self, input)  
    subscribeNext:^(NSString* x){  
        request(x);//發(fā)送一個(gè)請(qǐng)求  
   }];  

每次input值被修改時(shí)，就會(huì)調(diào)用此block，并且把修改后的值做為參數(shù)傳進(jìn)來(lái)。

doNext

doNext類似于subscribeNext。只不過(guò)doNext是直接跟在事件后，通常block沒有返回值，切block參數(shù)也不作處理，只是簡(jiǎn)單的附加操作，并不改變事件本身。

• 場(chǎng)景：點(diǎn)擊按鈕的同時(shí)把相關(guān)屬性置為YES
• 實(shí)現(xiàn)：

[[self.signInButton
   rac_signalForControlEvents:UIControlEventTouchUpInside]
   doNext:^(id x){
     self.signInButton.enabled =NO;
     self.signInFailureText.hidden =YES;
   }]

控件信號(hào)

使用rac_textSignal來(lái)返回text變化量，替代textField代理

• 場(chǎng)景：上面場(chǎng)景是監(jiān)聽自己的成員變量，如果想監(jiān)聽UITextField輸入值變化，框架也做了封裝可以代替系統(tǒng)回調(diào)
  實(shí)現(xiàn)：

[[self.priceInput.rac_textSignal  
     filter:^(NSString *str) {  
         if (str.integerValue > 20) {  
             return YES;  
         } else {  
             return NO;  
         }  
     }]  
     subscribeNext:^(NSString *str) {  
          request(x);//發(fā)送一個(gè)請(qǐng)求 
      }

使用rac_signalForControlEvents來(lái)添加點(diǎn)擊事件，替代addTarget

• 場(chǎng)景：按鈕添加點(diǎn)擊事件
  實(shí)現(xiàn)：

    [[button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(id x) {
        @strongify(self);
        if (self.addDeviceBlock) {
            self.addDeviceBlock();
        }
    }];

filter

使用filter對(duì)信號(hào)進(jìn)行篩選過(guò)濾，通過(guò)返回的BOOL值過(guò)濾信號(hào)，表示經(jīng)過(guò)filter篩選后的信號(hào)，和原信號(hào)類型一致。

• 場(chǎng)景：在上面場(chǎng)景中，當(dāng)用戶輸入的值以2開頭時(shí)，才發(fā)請(qǐng)求.
  實(shí)現(xiàn)：

[[RACObserve(self, input)  
     filter:^(NSString* value){  
         if ([value hasPrefix:@"2"]) {  
             return YES;  
         } else {  
             return NO;  
         }  
     }]  
     subscribeNext:^(NSString* x){  
        request(x);//發(fā)送一個(gè)請(qǐng)求  
    }]; 

注意：
雖然filter內(nèi)部返回的是BOOL類型，但是只用于過(guò)濾源信號(hào)，過(guò)濾后的值為2開頭的字符串，仍為字符串。

RAC()

RAC宏允許直接把信號(hào)的輸出應(yīng)用到對(duì)象的屬性上。RAC宏有兩個(gè)參數(shù)，第一個(gè)是需要設(shè)置屬性值的對(duì)象，第二個(gè)是屬性名。每次信號(hào)產(chǎn)生一個(gè)next事件，傳遞過(guò)來(lái)的值都會(huì)應(yīng)用到該屬性上。

• 場(chǎng)景：使用RAC宏替代在subscribeNext中賦值
  實(shí)現(xiàn)：

    [[validPasswordSignal
      map:^id(NSNumber *passwordValid){
          return[passwordValid boolValue] ? [UIColor clearColor]:[UIColor yellowColor];
      }]
     subscribeNext:^(UIColor *color){
         self.passwordTextField.backgroundColor = color;
     }];
    
    //替換為
     RAC(self.usernameTextField, backgroundColor) = [validPasswordSignal
     map:^id(NSNumber *passwordValid){
         return[passwordValid boolValue] ? [UIColor clearColor]:[UIColor yellowColor];
     }];

map

使用map對(duì)信號(hào)進(jìn)行轉(zhuǎn)換處理，改變信號(hào)內(nèi)類型，可以多次使用，為最常使用的方法。

• 場(chǎng)景：根據(jù)用戶名輸入是否可用來(lái)改變密碼輸入框背景色
  實(shí)現(xiàn)：

    RAC(self.pwdInputField, backgroundColor) =
    [[self.userNameInputField.rac_textSignal
      map:^id(NSString *text) {
          return @([self isValidPassword:text]);
      }] map:^id(NSNumber *passwordValid) {
          return[passwordValid boolValue] ? [UIColor clearColor]:[UIColor yellowColor];
      }];

先使用map對(duì)輸入值是否可用進(jìn)行判斷，返回NSNumber類型結(jié)果，再對(duì)該結(jié)果進(jìn)行判斷，返回UIColor類型，為真時(shí)使用透明色，不為真時(shí)使用黃色提示用戶。

flattenMap

當(dāng)信號(hào)中包含信號(hào)時(shí)，使用flattenMap，作用類似于map。

   flattenMap:^id(id x){
     return[self signInSignal];
   }]

其中signInSiganal方法返回的是racSignal類型。

同時(shí)監(jiān)聽多個(gè)變量變化

combineLatest，reduce

使用RACSignal combineLatest方法同時(shí)監(jiān)聽多個(gè)變量，參數(shù)為信號(hào)數(shù)組。使用RACObserve()將Object包裝成信號(hào)類型，或者使用控件的rac_textSignal屬性來(lái)返回信號(hào)。
使用reduce來(lái)處理多個(gè)監(jiān)聽信號(hào)的返回量，以信號(hào)形式返回任意對(duì)象類型，可用subscribeNext進(jìn)行下一步處理，也可直接賦予RAC宏中對(duì)象的屬性上。

• 場(chǎng)景：button監(jiān)聽 兩個(gè)輸入框有值和一個(gè)成員變量值，當(dāng)輸入框均有輸入且成員變量為真時(shí)，button為可點(diǎn)擊狀態(tài)
  實(shí)現(xiàn)：

RAC(self.payButton,enabled) = [RACSignal  
                                   combineLatest:@[self.priceInput.rac_textSignal,  
                                                self.nameInput.rac_textSignal,  
                                                RACObserve(self, isConnected)  
                                                ]  
                                   reduce:^(NSString *price, NSString *name, NSNumber *connect){  
                                   return @(price.length > 0 && name.length > 0 && [connect boolValue]);  
                                   }];  

• 場(chǎng)景：滿足上面條件時(shí)，直接發(fā)送請(qǐng)求
  實(shí)現(xiàn)：

[[RACSignal  combineLatest:@[self.priceInput.rac_textSignal,  
                                                self.nameInput.rac_textSignal,  
                                                RACObserve(self, isConnected)  
                                                ]  
                                   reduce:^(NSString *price, NSString *name, NSNumber *connect){  
                                   return @(price.length > 0 && name.length > 0 && ![connect boolValue]);  
                                   }]  
                             subscribeNext:^(NSNumber *res){  
                                 if ([res boolValue]) {  
                                     NSLog(@"XXXXX send request");  
                                 }  
                             }]; 

• 場(chǎng)景：兩個(gè)變量其中一個(gè)改變時(shí)更新label，或者由兩個(gè)變量共同作用同一個(gè)label
  實(shí)現(xiàn)1：

    [[RACSignal  combineLatest:@[RACObserve(device, config.className), RACObserve(device, cloudDevice.name) ]
                        reduce:^(NSString *className, NSString *name){
                            return [NSString stringWithFormat:@"%@%@",className,[name substringFromIndex:name.length - 4]];
                        }]
     subscribeNext:^(NSString *text){
             self.deviceNameLabel.text = text;
     }];

實(shí)現(xiàn)2：
RAC宏允許直接把信號(hào)的輸出應(yīng)用到對(duì)象的屬性上。RAC宏有兩個(gè)參數(shù)，第一個(gè)是需要設(shè)置屬性值的對(duì)象，第二個(gè)是屬性名。每次信號(hào)產(chǎn)生一個(gè)next事件，傳遞過(guò)來(lái)的值都會(huì)應(yīng)用到該屬性上。

 RAC(self.deviceNameLabel,text) = [RACSignal  combineLatest:@[RACObserve(device,config.className), RACObserve(device, cloudDevice.name) ]
                                                         reduce:^(NSString *className, NSString *name){
                                                             return [NSString stringWithFormat:@"%@%@",className,name];
                                                         }];

注意：上述兩個(gè)實(shí)現(xiàn)方法均可。但要注意combineLatest里的數(shù)組元素是信號(hào)類型，要用RACObserve()來(lái)封裝object;

實(shí)例

包含接口在內(nèi)的登錄操作，主體方法如下：

[[[[self.signInButton
    rac_signalForControlEvents:UIControlEventTouchUpInside]
   doNext:^(id x){
       self.signInButton.enabled =NO;
       self.signInFailureText.hidden =YES;
   }]
  flattenMap:^id(id x){
      return[self signInSignal];
  }]
 subscribeNext:^(NSNumber*signedIn){
     self.signInButton.enabled =YES;
     BOOL success =[signedIn boolValue];
     self.signInFailureText.hidden = success;
     if(success){
         [self performSegueWithIdentifier:@"signInSuccess" sender:self];
     }
 }];

點(diǎn)擊登錄按鈕后，利用doNext方法，附加設(shè)定登錄按鈕不可用，登錄失敗提示隱藏。
再使用flattenMap執(zhí)行登錄接口。
對(duì)于登錄接口返回signedIn進(jìn)行處理。重新設(shè)定登錄按鈕可用，根據(jù)signedIn設(shè)定失敗提示是否隱藏，以及是否進(jìn)行成功后的下一步處理。
其中signInSignal方法如下：

- (RACSignal *)signInSignal {
return [RACSignal createSignal:^RACDisposable *(id subscriber){
   [self.signInService 
     signInWithUsername:self.usernameTextField.text
               password:self.passwordTextField.text
               complete:^(BOOL success){
                    [subscriber sendNext:@(success)];
                    [subscriber sendCompleted];
     }];
   return nil;
}];
}

使用RACSignal的createSignal:方法來(lái)創(chuàng)建信號(hào)。方法的入?yún)⑹且粋€(gè)block，這個(gè)block描述了這個(gè)信號(hào)。當(dāng)這個(gè)信號(hào)有subscriber時(shí)，block里的代碼就會(huì)執(zhí)行。
block的入?yún)⑹且粋€(gè)subscriber實(shí)例，它遵循RACSubscriber協(xié)議，協(xié)議里有一些方法來(lái)產(chǎn)生事件，你可以發(fā)送任意數(shù)量的next事件，或者用error\complete事件來(lái)終止。本例中，信號(hào)發(fā)送了一個(gè)next事件來(lái)表示登錄是否成功，隨后是一個(gè)complete事件。
這個(gè)block的返回值是一個(gè)RACDisposable對(duì)象，它允許你在一個(gè)訂閱被取消時(shí)執(zhí)行一些清理工作。當(dāng)前的信號(hào)不需要執(zhí)行清理操作，所以返回nil就可以了。
實(shí)際上是將一個(gè)普通方法封裝成信號(hào)類型的方法，便于主體方法內(nèi)對(duì)此使用subscribeNext等信號(hào)處理方法進(jìn)行后續(xù)處理。

終止RAC

在RAC中執(zhí)行完某些操作后不再檢測(cè)反復(fù)執(zhí)行。

__block RACDisposable *handler = [RACObserve(self.device.currentcylinder.displayBoard, standby) subscribeNext:^(id x) {
    if ([x boolValue]) {
        self.device.currentcylinder.program = _cardLocalModel.program;
        [self runGroupCommond];
        [handler dispose];
    }
}];

另一種寫法：

RACSignal *backgroundColorSignal =
  [self.searchText.rac_textSignal
       map:^id(NSString *text) {
             return [self isValidSearchText:text] ?
               [UIColor whiteColor] : [UIColor yellowColor];
           }];
  
RACDisposable *subscription =
  [backgroundColorSignal
       subscribeNext:^(UIColor *color) {
             self.searchText.backgroundColor = color;
           }];
  
// at some point in the future ...
[subscription dispose];

避免RAC中的循環(huán)引用

ReactiveCocoa框架包含了一個(gè)小訣竅，你可以使用它代替上百年的代碼。添加下面的引用：

#import "RACEXTScope.h"

如下：

@weakify(self)
[[self.searchText.rac_textSignal
  map:^id(NSString *text) {
      return [self isValidSearchText:text] ?
      [UIColor whiteColor] : [UIColor yellowColor];
  }]
 subscribeNext:^(UIColor *color) {
     @strongify(self)
     self.searchText.backgroundColor = color;
 }];

可以把RACEXTScope.h放在全局頭文件引用中。

完整使用代碼

[[[[[[[self requestAccessToTwitterSignal]
  then:^RACSignal *{
    @strongify(self)
    return self.searchText.rac_textSignal;
  }]
  filter:^BOOL(NSString *text) {
    @strongify(self)
    return [self isValidSearchText:text];
  }]
  throttle:0.5]
  flattenMap:^RACStream *(NSString *text) {
    @strongify(self)
    return [self signalForSearchWithText:text];
  }]
  deliverOn:[RACScheduler mainThreadScheduler]]
  subscribeNext:^(NSDictionary *jsonSearchResult) {
    NSArray *statuses = jsonSearchResult[@"statuses"];
    NSArray *tweets = [statuses linq_select:^id(id tweet) {
      return [RWTweet tweetWithStatus:tweet];
    }];
    [self.resultsViewController displayTweets:tweets];
  } error:^(NSError *error) {
    NSLog(@"An error occurred: %@", error);
  }];

requestAccessToTwitterSignal方法:

- (RACSignal *)requestAccessToTwitterSignal {
 
  // 1 - define an error
  NSError *accessError = [NSError errorWithDomain:RWTwitterInstantDomain
                                             code:RWTwitterInstantErrorAccessDenied
                                         userInfo:nil];
  // 2 - create the signal
  @weakify(self)
  return [RACSignal createSignal:^RACDisposable *(id subscriber) {
    // 3 - request access to twitter
    @strongify(self)
    [self.accountStore
       requestAccessToAccountsWithType:self.twitterAccountType
         options:nil
      completion:^(BOOL granted, NSError *error) {
          // 4 - handle the response
          if (!granted) {
            [subscriber sendError:accessError];
          } else {
            [subscriber sendNext:nil];
            [subscriber sendCompleted];
          }
        }];
    return nil;
  }];
}

signalForSearchWithText方法：

- (RACSignal *)signalForSearchWithText:(NSString *)text {
  
  // 1 - define the errors
  NSError *noAccountsError = [NSError errorWithDomain:RWTwitterInstantDomain
                                                 code:RWTwitterInstantErrorNoTwitterAccounts
                                             userInfo:nil]; 
  NSError *invalidResponseError = [NSError errorWithDomain:RWTwitterInstantDomain
                                                      code:RWTwitterInstantErrorInvalidResponse
                                                  userInfo:nil]; 
  // 2 - create the signal block
  @weakify(self)
  return [RACSignal createSignal:^RACDisposable *(id subscriber) {
    @strongify(self); 
    // 3 - create the request
    SLRequest *request = [self requestforTwitterSearchWithText:text]; 
    // 4 - supply a twitter account
    NSArray *twitterAccounts = [self.accountStore
      accountsWithAccountType:self.twitterAccountType];    if (twitterAccounts.count == 0) {
      [subscriber sendError:noAccountsError];    } else {
      [request setAccount:[twitterAccounts lastObject]]; 
      // 5 - perform the request
      [request performRequestWithHandler: ^(NSData *responseData,                                          NSHTTPURLResponse *urlResponse, NSError *error) {
        if (urlResponse.statusCode == 200) {
  
          // 6 - on success, parse the response
          NSDictionary *timelineData =
             [NSJSONSerialization JSONObjectWithData:responseData
                                             options:NSJSONReadingAllowFragments
                                               error:nil];          [subscriber sendNext:timelineData];          [subscriber sendCompleted];        }
        else {
          // 7 - send an error on failure
          [subscriber sendError:invalidResponseError];        }
      }];    }
  
    return nil;  }];}

signalForLoadingImage方法：

-(RACSignal *)signalForLoadingImage:(NSString *)imageUrl {
  
  RACScheduler *scheduler = [RACScheduler
                         schedulerWithPriority:RACSchedulerPriorityBackground];
  
  return [[RACSignal createSignal:^RACDisposable *(id subscriber) {
    NSData *data = [NSData dataWithContentsOfURL:[NSURL URLWithString:imageUrl]];
    UIImage *image = [UIImage imageWithData:data];
    [subscriber sendNext:image];
    [subscriber sendCompleted];
    return nil;
  }] subscribeOn:scheduler];
  
}