ReactiveCocoa 学习笔记
Tip: 自己开发了好玩的APP： 《小明搜索》（App Store上搜索："小明搜索"）
[点击下载 "小明搜索"](https://itunes.apple.com/cn/app/小明搜索/id1378798470?l=en&mt=8)
1、集必应、百度、搜狗为一体的搜索平台
2、用户随意收藏或添加自己喜欢的网站
3、网页文字播放功能
4、收藏网页的视频，本地播放
5、附加常用小工具
6、后台播放网页音频
7、3D Touch提供便捷入口
完全自定义的搜索助手，简约的爱不释手~
该APP不断完善中~
#pragma mark - 各种方便的block封装 ReactiveCocoa
/*
概述：
可以把信号想象成水龙头，只不过里面不是水，而是玻璃球(value)，直径跟水管的内径一样，这样就能保证玻璃球是依次排列，不会出现并排的情况(数据都是线性处理的，不会出现并发情况)。水龙头的开关默认是关的，除非有了接收方(subscriber)，才会打开。这样只要有新的玻璃球进来，就会自动传送给接收方。可以在水龙头上加一个过滤嘴(filter)，不符合的不让通过，也可以加一个改动装置，把球改变成符合自己的需求(map)。也可以把多个水龙头合并成一个新的水龙头(combineLatest:reduce:)，这样只要其中的一个水龙头有玻璃球出来，这个新合并的水龙头就会得到这个球。
具体使用：
当一个signal被一个subscriber subscribe后，这个subscriber何时会被移除？答案是当subscriber被sendComplete或sendError时，或者手动调用[disposable dispose]。
当subscriber被dispose后，所有该subscriber相关的工作都会被停止或取消，如http请求，资源也会被释放。
Signal events是线性的，不会出现并发的情况，除非显示地指定Scheduler。所以-subscribeNext:error:completed:里的block不需要锁定或者synchronized等操作，其他的events会依次排队，直到block处理完成。
Errors有优先权，如果有多个signals被同时监听，只要其中一个signal sendError，那么error就会立刻被传送给subscriber，并导致signals终止执行。相当于Exception。
生成Signal时，最好指定Name, -setNameWithFormat: 方便调试。
block代码中不要阻塞。
*/
-(void)reactiveCocoaDemoAction{
// __weak typeof(self) wSelf = self;
// 因为RAC是基于KVO的，而NSMutableArray并不会在调用addObject或removeObject时发送通知
//------------------------------------通知监听----------------------------------------
[[[NSNotificationCenterdefaultCenter] rac_addObserverForName:@"log_out"object:nil] subscribeNext:^(id x) {
// NSNotification* notification = (NSNotification*)x;
// int unreadClubMsgCount = 0;
// if (notification.object) {
// unreadClubMsgCount = [notification.object intValue];
// }
//退出登录的通知。---"log_out"是自定义的
}];
//退出登录后执行。。。。上面的通知方法就可以触发了。
[[NSNotificationCenterdefaultCenter]postNotificationName:@"log_out"object:nil];
//------------------------------------UITextField输入限制-----------------------------
UITextField *textField;//自己写初始化
[textField.rac_textSignal subscribeNext:^(NSString* text) {
if(text.length > 12){
textField.text = [text substringToIndex:12];
}
}];
//------------------------------------UIAlertView,UIActionSheet点击方法-----------------------------
UIAlertView *alertView;//自己写初始化
[[alertView rac_buttonClickedSignal] subscribeNext:^(id x) {
if ([x integerValue] == 1) {//alert的按钮
}
}];
[alertView show];
UIActionSheet* actionSheet ;
[[actionSheet rac_buttonClickedSignal] subscribeNext:^(id x) {
if ([x integerValue] == 1) {//actionSheet的按钮
}
}];
// [actionSheet showInView:self.view];
//------------------------------------UIButton点击方法-----------------------------
UIButton *button;//自己写初始化
[[button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(id x) {
}];
//点击事件拦截。
[[[button rac_signalForControlEvents:UIControlEventTouchUpInside]filter:^BOOL(UIButton *button) {
if ([button.currentTitle isEqualToString:@"sd"]) {
return YES;
}else{
return NO;
}
}]subscribeNext:^(id x) {
NSLog(@"点击事件");
}];
//------------------------------------segmentedControl-----------------------------
UISegmentedControl *segmentedControl;
[[segmentedControl rac_signalForControlEvents:UIControlEventValueChanged] subscribeNext:^(id x) {
}];
//---------------------------------------------RAC-------------------------------------------
//---------------------------------------------RACObserver-------------------------------------------
// RAC() 可以将Signal发出事件的值赋值给某个对象的某个属性，其参数为对象名和属性名
// RACObserve() 参数为对象名和属性名，新建一个Signal并对对象的属性的值进行观察，当值变化时Signal会发出事件
//某个属性一发生变化就执行。
[RACObserve(self, count) subscribeNext:^(id x) {
if ([x integerValue] == 0) {
}else if ([x integerValue] > 100){
}
}];
//返回Bool赋值给createEnabled
RAC(self, createEnabled) = [RACSignal combineLatest:@[RACObserve(self, password),RACObserve(self, passwordConfirm)] reduce:^(NSString *pwd,NSString *pwdConfirm) {
return @([pwd isEqualToString:pwdConfirm]);
}];
//--------------------------------------------map 用法 --------------------------------------------
//map 改变返回的类型给结果管道。
[[self.textField.rac_textSignal map:^id(NSString *text) {
if ([text isEmptyString]) {
return [UIColor whiteColor];
}else{
return [UIColor yellowColor];
}
}]subscribeNext:^(UIColor *color) {
self.textField.backgroundColor = color;
}];
[[[self.buttonrac_signalForControlEvents:UIControlEventTouchUpInside]map:^id(UIButton *button) {
if ([button.currentTitle isEqualToString:@"按钮"]) {
return [NSString stringWithFormat:@"按钮"];
}else{
return [NSString stringWithFormat:@"不是按钮"];
}
}]subscribeNext:^(NSString *resultString) {
NSLog(@"%@",resultString);
}];
//--------------------------------------------filter 用法 --------------------------------------------
//filter某个属性满足一定条件才执行。
[[RACObserve(self, count) filter:^BOOL(id count) {//返回的是BOOL类型
if ([count integerValue] == 5) {
return YES;
}else{
return NO;
}
}]subscribeNext:^(id count) {//上面return YES 才走这里
NSLog(@"数量为===%@",count);
}];
//--------------------------------------------rac_command 用法 --------------------------------------------
self.button.rac_command = [[RACCommandalloc]initWithSignalBlock:^RACSignal *(id input) {
NSLog(@"按钮点击了。");
// [RACSignal return:@(6)];
return [RACSignal empty];
}];
//----------------------------------------RACDisposable 用法 --------------------------------------------
RACSignal *backgrountColorSignal = [self.textField.rac_textSignal map:^id(NSString *text) {
if ([text isEmptyString]) {
return [UIColor whiteColor];
}else{
return [UIColor greenColor];
}
}];
//subscrbeNext: 返回的类型是 RACDisposable
RACDisposable *subscription = [backgrountColorSignal subscribeNext:^(UIColor *color) {
self.textField.backgroundColor = color;
}];
//----------------------------------------combineLaster 用法 --------------------------------------------
//将self.button.enables 属性 和 右边的signal sendNext 值绑定。
RAC(self.button,enabled) = [RACSignal combineLatest:@[self.password,self.textField.rac_textSignal,RACObserve(self, passwordConfirm)] reduce:^(NSString *password,NSString *textString,NSString *passwordConfirm){
if ([password isEqualToString:passwordConfirm] && textString.length > 0) {
return @(YES);
}else{
return @(NO);
}
}];
//----------------------------------------RACSignal创建使用--------------------------------------------
// 当一个signal被一个subscriber subscribe后，这个subscriber何时会被移除？答案是当subscriber被sendComplete或sendError时，或者手动调用[disposable dispose]。
RACSignal *signal = [RACSignalcreateSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
NSLog(@"当前值");
[subscriber sendNext:@"下个值"];
[subscriber sendCompleted];
return nil;
}];//创建了一个 signal 但是没有 被subscribe 所有上面都不会发生。
//单独执行这句会输出 当前值 完成1
[signal subscribeCompleted:^{
NSLog(@"完成了1");
}];
//单独执行这句 会输出 当前值 x2===下个值
[signal subscribeNext:^(id x) {
NSLog(@"x2===%@",x);
}];
//单独执行这句 会输出 当前值 x3===下个值 完成了3
[signal subscribeNext:^(id x) {
NSLog(@"x3====%@",x);
} completed:^{
NSLog(@"完成了3");
}];
//---------------------------------------- RACSignal merge zipWith------------------------------------
RACSignal *signalA = [RACSignalcreateSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"A"];
return nil;
}];//创建了一个 signal 但是没有 被subscribe 所有上面都不会发生。
RACSignal *signalB = [RACSignalcreateSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"B"];
return nil;
}];
RACSignal *mergeSignal = [signalA merge:signalB];//任何一个信号发出都会执行。
[mergeSignal subscribeNext:^(id x) {
NSLog(@"%@",x); ///会两个输出： A B
}];
RACSignal *zipSignal = [signalA zipWith:signalB];//两个信号都发出才会执行
[zipSignal subscribeNext:^(id x) {
NSLog(@"%@",x);///会输出一个数组（A ,B） <RACTuple: 0x7fd61c82b1d0>
}];
RACSignal *combineSignal = [signalA combineLatestWith:signalB];
[combineSignal subscribeNext:^(id x) {
NSLog(@"%@",x);//会输出一个数组（A ,B） <RACTuple: 0x7fd61c82b1d0>
}];
RACSignal *reduceSignal = [RACSignal combineLatest:@[signalA,signalB] reduce:^id(NSString *str1,NSString *str2){
return [NSString stringWithFormat:@"%@ %@",str1,str2];
}];
[reduceSignal subscribeNext:^(id x) {
NSLog(@"%@",x);//合并后的字符串 A B
}];
//---------------------------------------- RACSubject 是 RACSignal 的子类------------------------------------
// subjects 表现为RACSubject类，可以认为是“可变的（mutable）”信号/自定义信号，它是嫁接非RAC代码到Signals世界的桥梁，很有用。嗯。。。这样讲还是很抽象，举个例子吧：
RACSubject *letters = [RACSubject subject];
[letters sendNext:@"a"];
// 可以看到@"a"只是一个NSString对象，要想在水管里顺利流动，就要借RACSubject的力。
//---------------------------------------- RACSequence有个属性是 RACSignal---------------------------
// sequence 表现为RACSequence类，可以简单看做是RAC世界的NSArray，RAC增加了-rac_sequence方法，可以使诸如NSArray这些集合类（collection classes）直接转换为RACSequence来使用。
NSArray *arr = [NSArray arrayWithObjects:@"arr1",@"arr2", nil];
NSMutableArray *array = [NSMutableArrayarray];
RACSequence *sequence = [arr rac_sequence];
[[[sequence.signal map:^id(id value) {
[array addObject:value];
return array;
}] filter:^BOOL(NSArray *resultArray) {
if (resultArray.count < 2) {
return NO;
}else{
return YES;
}
}] subscribeNext:^(id x) {
NSLog(@"x===%@",x);
}];
//---------------------------------------- scheduler 定时器------------------------------------
// scheduler 表现为RACScheduler类，类似于GCD，but schedulers support cancellationbut schedulers support cancellation, and always execute serially
/**
* @brief 创建一个定时器信号，每三秒发出一个当时日期值。一共发5次。
*/
RACSignal *signalInterval = [RACSignalinterval:3.0onScheduler:[RACSchedulermainThreadScheduler]];
signalInterval = [signalInterval take:5];//总共5次。
[signalInterval subscribeNext:^(id x) {
NSLog(@"x====%@",x);///x====2015-12-30 04:05:50 +0000
}];
}