iOS 之ReactiveCocoa
栏目: Objective-C · 发布时间: 5年前
内容简介:目录1 .RACSignal2 .RACSubject
目录
-
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] --->
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
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Redis设计与实现
黄健宏 / 机械工业出版社 / 2014-6 / 79.00
【官方网站】 本书的官方网站 www.RedisBook.com 提供了书本试读、相关源码下载和勘误回报等服务,欢迎读者浏览和使用。 【编辑推荐】 系统而全面地描述了 Redis 内部运行机制 图示丰富,描述清晰,并给出大量参考信息,是NoSQL数据库开发人员案头必备 包括大部分Redis单机特征,以及所有多机特性 【读者评价】 这本书描述的知识点很丰富,......一起来看看 《Redis设计与实现》 这本书的介绍吧!