iOS 之ReactiveCocoa

目录

• MVVM 架构

• 介绍 ReactiveCocoa

1 .RACSignal

2 .RACSubject

3 . RACReplaySubjec

4 . RACMulticastConnection

5 .RACComman

1.ReactiveCocoa简介

ReactiveCocoa（简称为RAC）,是由Github开源的一个应用于iOS和OS开发的新框架: https://github.com/ReactiveCocoa/ReactiveCocoa

ReactiveCocoa是一个高度抽象的编程框架，它真的很抽象，初看你不知道它是要干嘛的，等你用上了之后，就发现，有了它你是想干嘛就干嘛，编码从未如此流畅。它就像中国的太极，太极生两仪，两仪生四象，四象生八卦，八卦生万物。(ps:这话不是我说的 )

2.MVVM 架构

（参考： http://www.sprynthesis.com/2014/12/06/reactivecocoa-mvvm-introduction/ ）

MVC

任何一个正经开发过一阵子软件的人都熟悉MVC，它意思是Model View Controller, 是一个在复杂应用设计中组织代码的公认模式. 它也被证实在 iOS 开发中有着第二种含义: Massive View Controller(重量级视图控制器)。它让许多 程序员 绞尽脑汁如何去使代码被解耦和组织地让人满意. 总的来说得出结论: 他们需要给视图控制器瘦身, 并进一步分离业务逻辑;

MVVM

于是MVVM流行起来, 它代表Model View View-Model, 它在这帮助我们创建更易处理, 更佳设计的代码.

定义：

Model： 在 MVVM 中没有真正的变化. 取决于你的偏好, 你的 model 可能会或可能不会封装一些额外的业务逻辑工作。

View ：包含实际 UI 本身(不论是 UIView 代码, storyboard 和 xib), 任何视图特定的逻辑, 和对用户输入的反馈. 在 iOS 中这不仅需要 UIView 代码和那些文件, 还包括很多需由 UIViewController 处理的工作。

View-Model ：这个术语本身会带来困惑, 因为它混搭了两个我们已知的术语, 但却是完全不同的东东. 它的职责之一就是作为一个表现视图显示自身所需数据的静态模型;但它也有收集, 解释和转换那些数据的责任. 这留给了 view (controller) 一个更加清晰明确的任务: 呈现由 view-model 提供的数据。（说白了就是数据的请求，到模型化再到解释到view）

也许你有注意到没有控制器：我们并没有真的去除视图控制器的概念或抛弃 “controller” 术语来匹配 MVVM。我们正要将重合的那块工作剥离到 view-model 中, 并让视图控制器的生活更加简单。

View-Model 实例

我们的 view-model 头文件应该长这样:

//MYTwitterLookupViewModel.h
@interface MYTwitterLookupViewModel: NSObject
  
@property (nonatomic, assign, readonly, getter=isUsernameValid) BOOL usernameValid;
@property (nonatomic, strong, readonly) NSString *userFullName;
@property (nonatomic, strong, readonly) UIImage *userAvatarImage;
@property (nonatomic, strong, readonly) NSArray *tweets;
@property (nonatomic, assign, readonly) BOOL allTweetsLoaded;
  
@property (nonatomic, strong, readwrite) NSString *username;
  
- (void) getTweetsForCurrentUsername;
- (void) loadMoreTweets;

相当直截了当的填充. 注意到这些壮丽的 readonly 属性了么?这个 view-model 暴漏了视图控制器所必需的最小量信息, 视图控制器实际上并不在乎 view-model 是如何获得这些信息的. 现在我们两者都不在乎. 仅仅假定你习惯于标准的网络服务请求, 校验, 数据操作和存储.

view-model 不做的事儿

对视图控制器以任何形式直接起作用或直接通告其变化 View Controller(视图控制器)

视图控制器从 view-model 获取的数据将用来:

当 usernameValid 的值发生变化时触发 “Go” 按钮的 enabled 属性

当 usernameValid 等于 NO 时调整按钮的 alpha 值为0. 5(等于 YES 时设为1. 0)

更新 UILable 的 text 属性为字符串 userFullName 的值

更新 UIImageView 的 image 属性为 userAvatarImage 的值

用 tweets 数组中的对象设置表格视图中的 cell (后面会提到)

当滑到表格视图底部时如果 allTweetsLoaded 为 NO, 提供一个 显示 “loading” 的 cell

视图控制器将对 view-model 起如下作用:

每当 UITextField 中的文本发生变化, 更新 view-model 上仅有的 readwrite 属性 username

当 “Go” 按钮被按下时调用 view-model 上的 getTweetsForCurrentUsername 方法

当到达表格中的 “loading” cell 时调用 view-model 上的 loadMoreTweets 方法

视图控制器不做的事儿:

发起网络服务调用

管理 tweets 数组

判定 username 内容是否有效

将用户的姓和名格式化为全名

下载用户头像并转成 UIImage(如果你习惯在 UIImageView 上使用类别从网络加载图片, 你可以暴漏 URL 而不是图片. 这样没有让 view-model 和 UIKit 更完全摆脱, 但我视 UIImage 为数据而非数据的确切显示. 这些东西不是固定死的. )

注意: 视图控制器总的责任是处理 view-model 中的变化.

介绍 ReactiveCocoa

1 .RACSignal

定义：

信号类,一般表示将来有数据传递，只要有数据改变，信号内部接收到数据，就会马上发出数据。

说明:

信号类(RACSiganl)，只是表示当数据改变时，信号内部会发出数据，它本身不具备发送信号的能力，而是交给内部一个订阅者去发出。

默认一个信号都是冷信号，也就是值改变了，也不会触发，只有订阅了这个信号，这个信号才会变为热信号，值改变了才会触发。

如何订阅信号：调用信号RACSignal的subscribeNext就能订阅。

代码

#import "RACSignalViewController.h"


@interface RACSignalViewController ()

@property(nonatomic,strong) id subscriber ;

@end

@implementation RACSignalViewController

- (void)viewDidLoad
{
    [super viewDidLoad];
    self.view.backgroundColor = [UIColor whiteColor];
    
    RACSignal * signal = [RACSignal createSignal:^RACDisposable * _Nullable(id
<racsubscriber>
   _Nonnull subscriber) {
        NSLog(@"block excute");
        [subscriber sendNext:@"haha"];
        _subscriber = subscriber ;//如果不保存的话就会自动[subscriber sendCompleted];
        RACDisposable * disponse = [RACDisposable disposableWithBlock:^{
            NSLog(@"当信号发送完成或者发送错误，就会自动执行这个block,执行完Block后，当前信号就不在被订阅了。");
        }];
        
        return disponse ;
    }];
    
    // 订阅信号
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",[NSString stringWithFormat:@"receive:%@",x]);
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",[NSString stringWithFormat:@"receive:%@",x]);
    }];
}

- (void)touchesBegan:(NSSet
 <uitouch nbsp="">
   *)touches withEvent:(UIEvent *)event
{
    [_subscriber sendNext:@"lol"];
    [_subscriber sendCompleted];
    [_subscriber sendNext:@"lalala"]; // 不会执行
}
 </uitouch>
</racsubscriber>

注意事项

• subscriber 需要保存，不保存则自动发送结束

• 每订阅一次，创建信号方法传入的block就会被执行一次。（不想这样参考RACMulticastConnection）；

• 每次订阅，都会创建一个subscriber,一次订阅对应一个subscriber ;

• RACSubscriber:表示订阅者的意思，用于发送信号，这是一个协议，不是一个类，只要遵守这个协议，并且实现方法才能成为订阅者。通过create创建的信号，都有一个订阅者，帮助他发送数据。

• RACDisposable:用于取消订阅或者清理资源，当信号发送完成或者发送错误的时候，就会自动触发它。不想监听某个信号时，可以通过它主动取消订阅信号。

初始化方法

- (void)doNext
{
    [[[[RACSignal createSignal:^RACDisposable *(id
<racsubscriber>
  subscriber) {
        
        _subscriber = subscriber ;
        return nil;
    }] doNext:^(id x) {
        // 执行[subscriber sendNext:@"1"];之前会调用这个Block
        NSLog(@"%@",[x stringByAppendingString:@"doNext"]);
    }] doCompleted:^{
        // 执行[subscriber sendCompleted];之前会调用这个Block
        NSLog(@"doCompleted");;
        
    }] subscribeNext:^(id x) {
        
        NSLog(@"%@",x);
    }];
}
// 设置延时
- (void)timeout
{
    RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id
 <racsubscriber>
   subscriber) {\
        
        //发送一个延时请求。
        return nil;
    }] timeout:10 onScheduler:[RACScheduler currentScheduler]];
    
    [signal subscribeNext:^(id x) {
        
        NSLog(@"%@",x);
    } error:^(NSError *error) {
        // 10秒后会自动调用
        NSLog(@"%@",error);
    }];
}
//定时器
- (void)timer
{
    [[RACSignal interval:1 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(id x) {
        
        NSLog(@"timer : %@",x);
    }];
}
//延时
- (void)delay
{
    [[[RACSignal createSignal:^RACDisposable *(id
  <racsubscriber>
    subscriber) {
        _delaySubscriber = subscriber ;
        [subscriber sendNext:@1];
        return nil;
    }] delay:2] subscribeNext:^(id x) {
        
        NSLog(@"%@",x);
    }];
}
// 只要失败，就会重新执行创建信号中的block,直到成功
- (void)retry
{
    __block int i = 10;
    [[[RACSignal createSignal:^RACDisposable *(id
   <racsubscriber>
     subscriber) {
        
        if (i--) {
            NSLog(@"报一个错误");
            [subscriber sendError:nil];
        }
        else
        {
           [subscriber sendNext:@"重要不报错了"];
        }
        return nil;
        
    }] retry] subscribeNext:^(id x) {
        
        NSLog(@"%@",x);
        
    } error:^(NSError *error) {
        
        
    }];
}
- (void)replay
{
    RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id
    <racsubscriber>
      subscriber) {
        
        
        [subscriber sendNext:@1];
        [subscriber sendNext:@2];
        
        return nil;
    }] replay];
    
    [signal subscribeNext:^(id x) {
        
        NSLog(@"第一个订阅者%@",x);
        
    }];
    
    [signal subscribeNext:^(id x) {
        
        NSLog(@"第二个订阅者%@",x);
        
    }];
}
// 节流
- (void)throttle
{
    RACSubject *signal = [RACSubject subject];
    // 节流，在一定时间（10秒）内，不接收任何信号内容，过了这个时间（10秒）获取最后发送的信号内容发出。
    [[signal throttle:10] subscribeNext:^(id x) {
        
        NSLog(@"%@",x);
    }];
}
    </racsubscriber>
   </racsubscriber>
  </racsubscriber>
 </racsubscriber>
</racsubscriber>

2 .RACSubject

定义

就是一个RACSignal,集成了 协议 。

说明

可以用来做代理使用

代码

RACSubject * subject = [RACSubject subject];

[subject subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",[NSString stringWithFormat:@"张三先关注一波:%@",x]);
}];
 
    
[subject subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",[NSString stringWithFormat:@"李四也关注一波:%@",x]);
}];
    
[subject sendNext:@"大红包"];

代替代理的场景

在第二个控制器内部通过segVC改变第一个控制里的label.

OneViewController 中代码：

#import "OneViewController.h"
#import "TwoViewController.h"

@interface OneViewController ()

@property (weak, nonatomic) IBOutlet UILabel *name;

@end

@implementation OneViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    // Do any additional setup after loading the view from its nib.
}

- (IBAction)jump:(id)sender
{
    TwoViewController * vc = [TwoViewController new];
    
    vc.subject = [RACSubject subject];
    
    [vc.subject subscribeNext:^(id  _Nullable x) {
        
        NSNumber * index = x ;
        _name.text = @[@"小明",@"小华",@"小芳"][index.intValue];
        
    }];
    
    [self.navigationController pushViewController:vc animated:YES];
}


@end
TwoViewController 中的代码

@interface TwoViewController ()

@property(nonatomic ,strong) RACSubject * subject ;

@end


@implementation TwoViewController

- (void)viewDidLoad
{
    [super viewDidLoad];
}

- (IBAction)change:(UISegmentedControl *)sender
{
    if (_subject)
    {
        [_subject sendNext:@(sender.selectedSegmentIndex)];
    }
}

注意

代理拿不到回调。只能正向传值 。

3 . RACReplaySubject

定义：

重复提供信号类，RACSubject的子类。

RACReplaySubject与RACSubject区别: RACReplaySubject可以先发送信号，在订阅信号，RACSubject就不可以。

说明 ：

使用场景一:如果一个信号每被订阅一次，就需要把之前的值重复发送一遍，使用重复提供信号类。

使用场景二:可以设置capacity数量来限制缓存的value的数量,即只缓充最新的几个值。

代码

- (void)viewDidLoad
{
    [super viewDidLoad];
    
    //大家好，我是土豪
    RACReplaySubject *replaySubject = [RACReplaySubject subject];
    
    //张三关注了土豪
    [replaySubject subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",[NSString stringWithFormat:@"张三收到红包：%@",x]);
    }];
    
    //土豪发红包了
    [replaySubject sendNext:@"1个亿"];
    
    //李四看张三发财了也关注了土豪，并表示红包没抢到，要求重发
    [replaySubject subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",[NSString stringWithFormat:@"李四收到红包：%@",x]);
    }];
    
    //土豪表示，钱不是问题，不但重发，还把之前你没抢到的也发给你。
    [replaySubject sendNext:@"1毛钱"];
    
}
log:

2017-03-30 12:26:54.890 ReactiveCocoa[39418:1278518] 张三收到红包：1个亿
2017-03-30 12:26:54.890 ReactiveCocoa[39418:1278518] 李四收到红包：1个亿
2017-03-30 12:26:54.890 ReactiveCocoa[39418:1278518] 张三收到红包：1毛钱
2017-03-30 12:26:54.891 ReactiveCocoa[39418:1278518] 李四收到红包：1毛钱

4 . RACMulticastConnection

定义

用于当一个信号，被多次订阅时，为了保证创建信号时，避免多次调用创建信号中的block，造成副作用，可以使用这个类处理。

说明

创建： RACMulticastConnection通过RACSignal的-publish或者-muticast:方法创建.

代码

NSLog(@"--->%@ ,times:%zd",subscriber,++times); 只会打印一次。


#import "RACMulticastConnectionViewController.h"

@interface RACMulticastConnectionViewController ()
{
    RACSignal *_signal ;
    id
<racsubscriber>
   _Nonnull _subscriber ;
}

@end

@implementation RACMulticastConnectionViewController

- (void)viewDidLoad
{
    [super viewDidLoad];
    
    __block NSInteger times ;
    
    RACSignal * signal = [RACSignal createSignal:^RACDisposable * _Nullable(id
 <racsubscriber>
    _Nonnull subscriber) {
        
        NSLog(@"--->%@ ,times:%zd",subscriber,++times);
        _subscriber = subscriber ;
        
        return nil ;
    }];
    
    
//    [signal subscribeNext:^(id  _Nullable x) {
//        
//        NSLog(@"1 --> %@",x);
//    }];
//    
//    [signal subscribeNext:^(id  _Nullable x) {
//        NSLog(@"2 --> %@",x);
//    }];
    
//    _signal = signal ;
    
    static RACMulticastConnection *connect = nil ;
    
    if (!connect)
    {
        connect = [signal publish] ;
    }
    
    [connect.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"RACMulticastConnection  -->   %@",x);
    }];
    
    [connect.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"RACMulticastConnection  -->   %@",x);
    }];
    
    [connect.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"RACMulticastConnection  -->   %@",x);
    }];
    
    [connect connect];
    
}

- (void)touchesBegan:(NSSet
  <uitouch nbsp="">
    *)touches withEvent:(UIEvent *)event
{
    [_subscriber sendNext:@"sendedData"];
}

@end
  </uitouch>
 </racsubscriber>
</racsubscriber>

注意

subsciber 会给所有的订阅者发送消息。（类似与RACSubject），虽然subScriber只被保存了一次。

点击屏幕后 log:

2017-03-30 12:39:11.736 ReactiveCocoa[39608:1284448] ---> ,times:1

2017-03-30 12:39:15.766 ReactiveCocoa[39608:1284448] RACMulticastConnection --> sendedData

2017-03-30 12:39:15.767 ReactiveCocoa[39608:1284448] RACMulticastConnection --> sendedData

2017-03-30 12:39:15.768 ReactiveCocoa[39608:1284448] RACMulticastConnection --> sendedData

5 .RACCommand

定义 ：

RAC中用于处理事件的类。可以把事件如何处理,事件中的数据如何传递，包装到这个类中，他可以很方便的监控事件的执行过程。比如：网络请求，点击事件等。

说明

RACCommand的实例能够决定是否可以被执行，这个特性能反应在UI上，而且它能确保在其不可用时不会被执行。通常，当一个命令可以执行时，会将它的属性allowsConcurrentExecution设置为它的默认值：NO，从而确保在这个命令已经正在执行的时候，不会同时再执行新的操作。命令执行的返回值是一个RACSignal，因此我们能对该返回值进行next:，completed或error:

代码

#import "RACCommandViewController.h"

@interface RACCommandViewController ()
{
    RACCommand * _command ;
}

@end

@implementation RACCommandViewController

- (void)viewDidLoad
{
    [super viewDidLoad];
    
    _command = [[RACCommand alloc] initWithSignalBlock:^RACSignal * _Nonnull(id  _Nullable input){
        
        RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id
<racsubscriber>
   _Nonnull subscriber) {
            
            NSLog(@"%@",input);
            MOBAWxArticleRequest * req = [MOBAWxArticleRequest wxArticleCategoryRequest];
            
            [MobAPI sendRequest:req onResult:^(MOBAResponse *response) {
                [subscriber sendNext:response.responder];
                [subscriber sendCompleted];
            }];
            
            return nil ;
        }] ;
        
        return signal ;
        
    }];
    
    
}
- (void)touchesBegan:(NSSet
 <uitouch nbsp="">
   *)touches withEvent:(UIEvent *)event
{
//    //先订阅
//    [_command.executionSignals subscribeNext:^(id  _Nullable x) {
//        
//        [x subscribeNext:^(id  _Nullable x) {
//            NSLog(@"normal -> %@",x);
//        }];
//    }];
    
    //也可以这样写
    [_command.executionSignals.switchToLatest subscribeNext:^(id  _Nullable x) {
        NSLog(@"vip --> %@",x);
    }];
    //监听command的状态
    [[_command.executing skip:1] subscribeNext:^(NSNumber * _Nullable x) {
        if (x.boolValue)
        {
            NSLog(@"excuting...");
        }
        else
        {
            NSLog(@"not excuted");
        }
    }];
    
    //在执行
    [_command execute:@"参数"];
    
}

@end
 </uitouch>
</racsubscriber>

注意

RACommand本身也是信号类, 属性executionSignals是一个信号中的信号 所以command执行，我得到的数据x时一个RACSignal包装的数据。需要再次订阅这个signal才能拿到数据。

以下初始化方法可以创建一个信号觉得command的状态是执行还是不可执行的。

• (instancetype)initWithEnabled:(nullable RACSignal *)enabledSignal signalBlock:(RACSignal * (^)(InputType _Nullable input))signalBlock;

6 . others

1. RACTuple:元组类

类似NSArray,用来包装值.

2. RACSequence:集合类

用于代替NSArray,NSDictionary,可以使用它来快速遍历数组和字典。

3. RACScheduler

针对RAC中的队列，GCD的封装。

4. RACEvent

把数据包装成信号事件(signalevent)。它主要通过RACSignal的-materialize来使用，然并卵

RACUnit

表stream不包含有意义的值,也就是看到这个，可以直接理解为nil.

实例代码

// 1.遍历数组
    NSArray *numbers = @[@1,@2,@3,@4];
    
    [numbers.rac_sequence.signal subscribeNext:^(id x) {
    
        NSLog(@"%@",x);
    }];
// 2.遍历字典,遍历出来的键值对会包装成RACTuple(元组对象)
    NSDictionary *dict = @{@"1":@"a",@"2":@"b"};
    [dict.rac_sequence.signal subscribeNext:^(RACTuple *x) {
    
        // 解包元组，会把元组的值，按顺序给参数里面的变量赋值
        RACTupleUnpack(NSString *key,NSString *value) = x;
        
        // 相当于以下写法
//        NSString *key = x[0];
//        NSString *value = x[1];

        NSLog(@"%@ %@",key,value);
        
    }];

7 . RAC 常用方法

1. rac_signalForSelector

NSObject的分类，hook的方式 ，返回参数x是原方法传入参数的tuple

[[self rac_signalForSelector:@selector(btnClick:)] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

2. rac_valuesAndChangesForKeyPath

KVO的RAC写法

[[self rac_valuesAndChangesForKeyPath:@"center" options:NSKeyValueObservingOptionNew observer:nil] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

3. rac_signalForControlEvents

把事件封装成singnal

[[btn rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(id x) {

        NSLog(@"%@"，x);
    }];

4. rac_addObserverForName

RAC 的通知写法

[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillShowNotification object:nil] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

5. rac_textSignal

监听文本框文字改变 只要文本框发出改变就会发出这个信号。

[_textField.rac_textSignal subscribeNext:^(id x) {

       NSLog(@"文字改变了%@",x);
   }];

6. rac_liftSelector:withSignalsFromArray:Signals:

当传入的Signals(信号数组)，每一个signal都至少sendNext过一次，就会去触发第一个selector参数的方法。

RACSignal *req1 = [RACSignal createSignal:^RACDisposable *(id
<racsubscriber>
  subscriber) {

        // 发送请求
        [subscriber sendNext:@"1"];
        return nil;
    }];
    
        RACSignal *req2 = [RACSignal createSignal:^RACDisposable *(id
 <racsubscriber>
   subscriber) {
        // 发送请求
        [subscriber sendNext:@"2"];
        return nil;
    }];
    
    // 使用注意：几个信号，参数一的方法就几个参数，每个参数对应信号发出的数据。
    [self rac_liftSelector:@selector(updateUIWith1:2:) withSignalsFromArray:@[request1,request2]];


}
// 更新UI
- (void)updateUIWith1:(id)x1 2:(id)x2
{
    NSLog(@"%@  %@",x1,x2);
}
 </racsubscriber>
</racsubscriber>

7. map 和 flattenMap （映射）

通过此方法可以在拿到信号发送的数据前 执行一些操作 在把我们操作操作过的值发送出去。

RACSignal *signal = [self.textFiled.rac_textSignal map:^id _Nullable(NSString * _Nullable value) {
        return [value stringByAppendingString:@"+修改一下"];
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

注意 ：信号数组的长度等于@selector的方法参数数量，响应方法的时候会被一一填充。

8 . RACSignal常见操作方法

1. concat :

按一定顺序拼接信号，当多个信号发出的时候，有顺序的接收信号。

代码：

//按一定顺序拼接信号，当多个信号发出的时候，有顺序的接收信号。

- (IBAction)concat:(id)sender
{
    NSLog(@"****************** concat ******************");
    
    id
<racsubscriber>
   __block subscriberA ;
    id
 <racsubscriber>
    __block subscriberB ;
    
    RACSignal * signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id
  <racsubscriber>
     _Nonnull subscriber) {
        subscriberA = subscriber ;
        return nil ;
    }];
    
    RACSignal * signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id
   <racsubscriber>
      _Nonnull subscriber) {
        subscriberB = subscriber ;
        return nil ;
    }];
    
    RACSignal *concatSignal = [signalA concat:signalB] ;
    [concatSignal subscribeNext:^(id  _Nullable x) {
        NSLog(@"concat:%@",x);
    }];
    
    [subscriberA sendNext:@"A"];
    [subscriberA sendCompleted];//一定要调complete
    
    [subscriberB sendNext:@"B"];
    
}
   </racsubscriber>
  </racsubscriber>
 </racsubscriber>
</racsubscriber>

说明：

如果subscriberB 先发送则不会有任何打印消息。

2. then :

用于连接两个信号，当第一个信号完成，才会连接then返回的信号。

代码

NSLog(@"****************** then ******************");
    id
<racsubscriber>
   __block subscriberA ;
    id
 <racsubscriber>
    __block subscriberThen ;
    
    RACSignal * signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id
  <racsubscriber>
     _Nonnull subscriber) {
        subscriberA = subscriber ;
        return nil ;
    }];
    
    RACSignal * signalThen = [signalA then:^RACSignal * _Nonnull{
        return [RACSignal createSignal:^RACDisposable * _Nullable(id
   <racsubscriber>
      _Nonnull subscriber) {
            subscriberThen = subscriber ;
            return nil ;
        }];
    }];
    
    //  A的订阅会被忽略掉。
    [signalA subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    [signalThen subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    [subscriberA sendNext:@"A"];
    [subscriberA sendCompleted];//一定要调complete
    
    [subscriberThen sendNext:@"B"];
    [subscriberThen sendCompleted];
   </racsubscriber>
  </racsubscriber>
 </racsubscriber>
</racsubscriber>

说明

A发送完成后一定要调sendCompleted ； A的订阅会被忽略。只有then信号的订阅收到信号。

3. merge ：

把多个信号合并为一个信号，任何一个信号有新值的时候就会调用.

代码

NSLog(@"****************** merge ******************");
    id
<racsubscriber>
   __block subscriberA ;
    id
 <racsubscriber>
    __block subscriberB ;
    
    RACSignal * signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id
  <racsubscriber>
     _Nonnull subscriber) {
        subscriberA = subscriber ;
        return nil ;
    }];
    
    RACSignal * signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id
   <racsubscriber>
      _Nonnull subscriber) {
        subscriberB = subscriber ;
        return nil ;
    }];
    
    // 合并信号,任何一个信号发送数据，都能监听到.
    RACSignal *mergeSignal = [signalA merge:signalB];
    
    [mergeSignal subscribeNext:^(id x) {
        
        NSLog(@"%@",x);
        
    }];
    
    [subscriberA sendNext:@"A sended"];
    [subscriberB sendNext:@"B sended"];
   </racsubscriber>
  </racsubscriber>
 </racsubscriber>
</racsubscriber>

4. zipWith:

把2个信号合并成一个信号，2个信号都发送时，zip信号才会发送消息。

NSLog(@"****************** zipWith ******************");
    id
<racsubscriber>
   __block subscriberA ;
    id
 <racsubscriber>
    __block subscriberB ;
    
    RACSignal * signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id
  <racsubscriber>
     _Nonnull subscriber) {
        subscriberA = subscriber ;
        return nil ;
    }];
    
    RACSignal * signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id
   <racsubscriber>
      _Nonnull subscriber) {
        subscriberB = subscriber ;
        return nil ;
    }];
    
    // 合并信号,任何一个信号发送数据，都能监听到.
    RACSignal *zipSignal = [signalA zipWith:signalB];
    
    [zipSignal subscribeNext:^(id x) {
        
        NSLog(@"%@",x);
        
    }];
    
    [subscriberA sendNext:@"A sended"];
    [subscriberB sendNext:@"B sended"];
    [subscriberA sendNext:@"A sended2"];
    [subscriberB sendNext:@"B sended2"];
   </racsubscriber>
  </racsubscriber>
 </racsubscriber>
</racsubscriber>

5. combineLatest:

将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。

代码

NSLog(@"****************** combineLatest ******************");
    id
<racsubscriber>
   __block subscriberA ;
    id
 <racsubscriber>
    __block subscriberB ;
    id
  <racsubscriber>
     __block subscriberC ;
    
    RACSignal * signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id
   <racsubscriber>
      _Nonnull subscriber) {
        subscriberA = subscriber ;
        return nil ;
    }];
    
    RACSignal * signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id
    <racsubscriber>
       _Nonnull subscriber) {
        subscriberB = subscriber ;
        return nil ;
    }];
    
    RACSignal * signalC = [RACSignal createSignal:^RACDisposable * _Nullable(id
     <racsubscriber>
        _Nonnull subscriber) {
        subscriberC = subscriber ;
        return nil ;
    }];
    
    // 合并信号,任何一个信号发送数据，都能监听到.
//    RACSignal *combineSignal = [[signalA combineLatestWith:signalB] combineLatestWith:signalC];
    
    RACSignal *combineSignal = [RACSignal combineLatest:@[signalA,signalB,signalC]];
    [combineSignal subscribeNext:^(id x) {
        
        NSLog(@"%@",x);
        
    }];
    
    [subscriberA sendNext:@"A sended"];
    [subscriberA sendNext:@"A sended 2"];
    
    [subscriberB sendNext:@"B sended"];
    
    [subscriberC sendNext:@"C sended"];
    [subscriberC sendNext:@"C sended 2"];
     </racsubscriber>
    </racsubscriber>
   </racsubscriber>
  </racsubscriber>
 </racsubscriber>
</racsubscriber>

说明

对比与zipWith,它会不停的更新为最新的值。

6. reduce:

就是c ombine 发送的信号 在reduce block里面处理后发送出去。

- (IBAction)reduce:(id)sender
{
    
    NSLog(@"****************** combineLatest ******************");
    id
<racsubscriber>
   __block subscriberA ;
    id
 <racsubscriber>
    __block subscriberB ;
    id
  <racsubscriber>
     __block subscriberC ;
    
    RACSignal * signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id
   <racsubscriber>
      _Nonnull subscriber) {
        subscriberA = subscriber ;
        return nil ;
    }];
    
    RACSignal * signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id
    <racsubscriber>
       _Nonnull subscriber) {
        subscriberB = subscriber ;
        return nil ;
    }];
    
    RACSignal * signalC = [RACSignal createSignal:^RACDisposable * _Nullable(id
     <racsubscriber>
        _Nonnull subscriber) {
        subscriberC = subscriber ;
        return nil ;
    }];
    
    // 合并信号,任何一个信号发送数据，都能监听到.
    //    RACSignal *combineSignal = [[signalA combineLatestWith:signalB] combineLatestWith:signalC];
    
    RACSignal *combineSignal = [RACSignal combineLatest:@[signalA,signalB,signalC] reduce:^id(NSString *a,NSString *b,NSString *c){
        
        return [@[a,b,c] componentsJoinedByString:@" + "];
    }];
    
    [combineSignal subscribeNext:^(id x) {
        
        NSLog(@"%@",x);
        
    }];
    
    [subscriberA sendNext:@"A sended"];
    [subscriberA sendNext:@"A sended 2"];
    
    [subscriberB sendNext:@"B sended"];
    
    [subscriberC sendNext:@"C sended"];
    [subscriberC sendNext:@"C sended 2"];
}
     </racsubscriber>
    </racsubscriber>
   </racsubscriber>
  </racsubscriber>
 </racsubscriber>
</racsubscriber>

7. filter ：

过滤信号，使用它可以获取满足条件的信号

代码

/* 过滤信号，使用它可以获取满足条件的信号 */
    [[_textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        return value.length > 3 ;
    }] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"filter -> %@",x);
    }];

8. ignore ：

忽略完某些值的信号

代码

[[_textField.rac_textSignal ignore:@"MOB"] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"ignore ->%@",x);
    }];

9. distinctUntilChanged

当上一次的值和当前的值有明显的变化就会发出信号，否则会被忽略掉

代码

[[_textField.rac_textSignal distinctUntilChanged] subscribeNext:^(id x) {
        
        NSLog(@"distinctUntilChanged -> %@",x);
    }];

10. take/takeLast

取前几次 / 取最后几次 发送的信号

代码

[[_textField.rac_textSignal take:2] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"take -> %@",x);
    }];
    
   [[_textField.rac_textSignal takeLast :3] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"takeLast -> %@",x);
    }];

说明

takeLast 一定要调用sendComplete。不然不知道什么是结束。也就没有最后的概念。返回的是tuple

11. skip

跳过几次信号发送

代码

[[_textField.rac_textSignal skip:2] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"skip -> %@",x);
    }];

9 .RAC 常用的宏

1. RAC(TARGET, ...)

// content属性值随着输入框值得变化而变化。

@property (nonatomic ,copy) NSString *content ;

RAC(self,content) = _textField.rac_textSignal ;

2.RACObserve(<#TARGET#>,<#KEYPATH#>)

[RACObserve(self, content) subscribeNext:^(id _Nullable x) {

NSLog(@"%@",x);

}];

3. @weakify(self)和@strongify(self)

一定要配套使用，实现原理：

@weakify(self);

[[self rac_signalForSelector:@selector(touchesBegan:withEvent:)] subscribeNext:^(id _Nullable x) {

@strongify(self);

NSLog(@" test ----> %@",x);

}];

__weak typeof(self) weakSelf = self ;
[[self rac_signalForSelector:@selector(touchesBegan:withEvent:)] subscribeNext:^(id  _Nullable x) {
    id self = weakSelf ;
    
    NSLog(@" test ----> %@",x);
}];

4. RACTuplePack(...) / RACTupleUnpack(...)

把数据包装成元组类/解析元组

RACTuple *tuple = RACTuplePack(@"1314",@20);

RACTupleUnpack(NSString *a,NSNumber *b) = tuple;

NSLog(@"%@,%@",a,b);

Reactive 5.0 更新

参考自： http://www.cocoachina.com/ios/20161116/18104.html

RAC 5.0 相比于 4.0 有了巨大的变化，不仅是受 swift 3.0 大升级的影响，RAC 对自身项目结构的也进行了大幅度的调整。这个调整就是将 RAC 拆分为四个库：ReactiveCocoa、ReactiveSwift、ReactiveObjC、ReactiveObjCBridge。

ReactiveCocoa

现在的 RAC 注意力主要集中在 Swift 和 UI 层上，将原来一个基于 RAC 面向 UI 层的扩展库 Rex 合并进了 RAC 。

RAC 3 和 4 的主要精力在围绕 Swift 重新打造一个响应式编程库。因为这部分的核心 API 已经很成熟，所以现在将重心放在为 AppKit 和 UIKit 提供一些更好用的扩展上。

ReactiveSwift

原来 RAC 中只和 Swift 平台相关的核心代码被单独抽取成了一个新框架：ReactiveSwift 。

Swift 正在快速成长并且成长为一个跨平台的语言。把只和 Swift 相关的代码抽取出来后，ReactiveSwift 就可以在其他平台上被使用，而不只是局限在 CocoaTouch 和 Cocoa 中。

ReactiveObjC

在 RAC 3 和 4 中，RAC 也包含了 RAC 2 中的 OC 代码。现在这部分代码被移到了 ReactiveObjC 。

这样做的原因是因为两个库虽然有着一样的核心编程范式，实际上却是完全独立的两套 API 。实际的使用中，RAC 4 和 RAC 2 是完全不同的两组用户群，并且维护的团队其实也是两组。之前混在一个库里也增加了管理的复杂度。拆分出去后也可以更加自由的维护 ReactiveObjC 。

ReactiveObjCBridge

在把 Swift 和 OC 的库拆分之后问题来了，并不是所有的库都是纯 OC 和 Swift 的。有相当大一部分项目处于 OC 迁移到 Swift 过程中，其中可能使用 Swift 调用了 RAC 2 中基于 OC 写的 API。为了解决这部分用户的问题，所以有了 ReactiveObjCBridge 。

大量的Api的改变和重命名。

比如API 都放在了 reactive 后。不再是原先的 rac_xx 。 增加了生命周期 lifetime 的属性等等 。

作者：天下林子

链接：https://www.jianshu.com/p/060699578bea