c的值会自动响应a的价值或b的价变化的信号。c的值会自动响应a的值或b的价值变化的信号。

相同、响应式编程范式FRP

FRP,全称为Functional Reactive
Programming,是均等种植响应变化的编程范式,最近几乎年较火,大概的明就是比如这样:

当a的值或者b的值发生变化时,c的值会自动响应a的价值或b的价变化的信号,自动重新凑巧自己之值,类似这种编程思想就是称FRP。

FRP提供了一如既往种植信号机制来兑现这样的功效,通过信号来记录值的变动。信号好给增大、分割或合并。通过对信号的组合,就非需去监听某个值或事件。

同等、响应式编程范式FRP

FRP,全称为Functional Reactive
Programming,是一律种植响应变化的编程范式,最近几年较火,大概的接头就是像这样:
图片 1
当a的价或者b的值发生变化时,c的值会自动响应a的价值或b的价值变化之信号,自动重新凑巧自己的值,类似这种编程思想便称为FRP。

FRP提供了一致栽信号机制来兑现这样的力量,通过信号来记录值的变更。信号好给增大、分割或合并。通过对信号的整合,就非需去监听某个值或事件。

二、ReactiveCocoa介绍

ReactiveCocoa凡github开源的一个叔正在框架,是于iOS平台上对FRP的兑现。
FRP的骨干是信号,信号于ReactiveCocoa(以下简称RAC)中凡经过RACSignal来代表的,信号是数据流,可以让绑定和传递。

二、ReactiveCocoa介绍

ReactiveCocoa举凡github开源的一个叔在框架,是在iOS平台达成对FRP的兑现。
FRP的中坚是信号,信号于ReactiveCocoa(以下简称RAC)中凡是由此RACSignal来代表的,信号是数据流,可以让绑定和传递。

下简单介绍下RAC的几个概念:
  1. Signal:信号管,可以想像变为水把
  1. Value:信号值,可以想象变为玻璃球
    得拿信号管(Signal)想象成道把,只不过里面未是趟,而是玻璃球(Value),直径跟水管的内径一样,这样就能确保玻璃球是逐一排列,不见面面世并排的状况(数据都是线性处理的,不见面出现并发情况)
  2. Subscriber:接受方,可以想象成道把出水口
    水把的开关默认是拉的,除非有矣接收方(Subscriber),才见面打开。这样使出新的弹子进来,就见面自动传递给接收方。
  3. Filter:过滤器
    足于历届把上加以一个过滤嘴(Filter),不入的非吃经
  4. Map:改动器
    可于道把上加一个转移装置(Map),把球改变成符合好的要求
下简单介绍下RAC的几乎独概念:
  1. Signal:信号管,可以想象成道把
  2. Value:信号值,可以设想变为玻璃球
    好管信号管(Signal)想象变为道把,只不过里面不是历届,而是玻璃球(Value),直径跟水管之内径一样,这样就是能够保证玻璃球是逐一排列,不会见产出并排的状(数据还是线性处理的,不会见油然而生并发情况)
  3. Subscriber:接受方,可以想象成和把出水口
    道把的开关默认是拉之,除非有矣接收方(Subscriber),才会打开。这样使有新的弹子进来,就见面自动传送给接收方。
  4. Filter:过滤器
    可以在回把上加以一个过滤嘴(Filter),不符合的无让经
  5. Map:改动器
    可以和把上加一个变更装置(Map),把球改变成适合好的要求

老三、ReactiveCocoa框架各组件

其三、ReactiveCocoa框架各组件

1. RACStream类

水管中流淌的一样密密麻麻玻璃球,它们有各个的相继通过,在第一单玻璃球没有到达之前,你没法获得第二只玻璃球,RACStream叙的饶是这种线性流动玻璃球的形状,比较空虚,是当描述抽象的父类,它本身的下意义并无特别可怜,一般会坐RACSignal或者RACSequence对等这些又强层次之变现形态代替。

1. RACStream类

水管中流淌的一样文山会海玻璃球,它们来各个的次第通过,在首先只玻璃球没有到达之前,你没法获得第二个玻璃球,RACStream讲述的虽是这种线性流动玻璃球的形态,比较抽象,是作为描述抽象的父类,它自身的下意义并无死酷,一般会因为RACSignal或者RACSequence齐这些再胜层次之显现形态代替。

RACStream的功用总结看下图:
RACStream的作用总结看下图:

图片 2

2. RACSignal类

RAC的主干概念就是Signal,它一般代表未来若是到的价值,想象玻璃球一个个打水龙头里出来,只发了接收方才能够取到这些玻璃球。
RACSignal会见发送下面三种事件于它的接受方,想象成道把出个指令灯来反映它的劳作状态,接受方通过-subscribeNext:error:completed:本着两样事件作出相应影响:

  1. Next:从水龙头里流出的初玻璃球
  1. Error:获取新的弹子发生了不当,一般要发送一个NSError对象,表明哪里错了
  2. Completed:全部玻璃球已经顺利抵达,没有重新多之弹子加入了

RACSignal可以发送任意多只Next事件,和一个Error或者Completed事件

2. RACSignal类

RAC的基本概念就是Signal,它一般代表未来要是达的价,想象玻璃球一个个由水龙头里下,只生矣接收方才会取到这些玻璃球。
RACSignal会晤发送下面三栽事件被其的接受方,想象变为和把出个指令灯来报告它的行事状态,接受方通过-subscribeNext:error:completed:针对不同事件作出相应影响:

  1. Next:从水龙头里流出的新玻璃球
  2. Error:获取新的弹子发生了左,一般只要发送一个NSError对象,表明哪里错了
  3. Completed:全部玻璃球已经胜利抵达,没有更多的弹子加入了

RACSignal可发送任意多个Next事件,和一个Error或者Completed事件

图片 3

3. RACSubject类

RACSubject类似,可以认为是“可变的(Mutable)”信号/自定义信号,它是嫁接非RAC代码到Signal世界之桥

3. RACSubject类

RACSubject看似,可以看是“可变的(Mutable)”信号/自定义信号,它是嫁接非RAC代码到Signal世界的桥梁
图片 4

4. RACCommand类

RACCommand类,可以认为是应对某些动作之信号,通常触发拖欠信号的动作还是UI控件

4. RACCommand类

RACCommand仿佛,可以看是回应某些动作的信号,通常触发拖欠信号的动作还是UI控件
图片 5

5. RACSequence类

RACSequence看似,可以略看做是RAC世界之NSArray,RAC增加了-rac_sequence法,可以要像NSArray这些集合类直接换为RACSequence来使用。

5. RACSequence类

RACSequence看似,可以略看做是RAC世界的NSArray,RAC增加了-rac_sequence方法,可以使像NSArray这些集合类直接换为RACSequence来使用。
图片 6

6. RACScheduler类

RACScheduler类,类似于GCD,但RACScheduler看似支持取消,并且连接运行安全之。
RACScheduler凡是RAC里当线程的简包装,事件可以以指定的RACScheduler直达散发及实行,不特别指定的话,事件之分发及执行还当一个默认的后台线程里面做,大多数动静为就是不用动了。
出一些奇之Signal必须在主线程调用,使用-deliverOn:好切换调用的线程。

6. RACScheduler类

RACScheduler类,类似于GCD,但RACScheduler接近支持取消,并且连续运行安全的。
RACScheduler凡RAC里当线程的简要包装,事件可以当指定的RACScheduler直达散发及实行,不特别指定的话,事件的散发及履行都以一个默认的后台线程里面做,大多数情况为不怕不用动了。
起有独特的Signal总得以主线程调用,使用-deliverOn:得切换调用的线程。
图片 7

季、ReactiveCocoa简单以20条例

季、ReactiveCocoa简单利用20章

1. 观察值变化
1. 观察值变化
而别动,你同样动自己不怕亮。
//当self.value的值变化时调用Block,这是用KVO的机制,RAC封装了KVO
@weakify(self);
[RACObserve(self, value) subscribeNext:^(NSString* x) {  
    @strongify(self);
    NSLog(@"你动了");
}];
汝别动,你一样动自己便掌握。
//当self.value的值变化时调用Block,这是用KVO的机制,RAC封装了KVO
@weakify(self);
[RACObserve(self, value) subscribeNext:^(NSString* x) {  
    @strongify(self);
    NSLog(@"你动了");
}];
2. 片面响应
2. 片面响应
卿唱歌,我就算跳舞。
//创建一个信号
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //这个信号里面有一个Next事件的玻璃球和一个Complete事件的玻璃球
    [subscriber sendNext:@"唱歌"];
    [subscriber sendCompleted];
    return nil;
}];
//对信号进行改进,当信号里面流的是”唱歌”,就改成”跳舞”返还给self.value
RAC(self, value) = [signalA map:^id(NSString *value) { 
    if ([value isEqualToString:@"唱歌"]) {
        return @"跳舞";
    }
    return @"";
}];
君唱,我就是跳舞。
//创建一个信号
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //这个信号里面有一个Next事件的玻璃球和一个Complete事件的玻璃球
    [subscriber sendNext:@"唱歌"];
    [subscriber sendCompleted];
    return nil;
}];
//对信号进行改进,当信号里面流的是”唱歌”,就改成”跳舞”返还给self.value
RAC(self, value) = [signalA map:^id(NSString *value) { 
    if ([value isEqualToString:@"唱歌"]) {
        return @"跳舞";
    }
    return @"";
}];
3. 两头响应
3. 两头响应
您于外来,他即便于东面,他向左,你虽向右侧。
//创建2个通道,一个从A流出的通道A和一个从B流出的通道B
RACChannelTerminal *channelA = RACChannelTo(self, valueA);
RACChannelTerminal *channelB = RACChannelTo(self, valueB);
//改造通道A,使通过通道A的值,如果等于"西",就改为"东"传出去
[[channelA map:^id(NSString *value) {
    if ([value isEqualToString:@"西"]) {
        return @"东";
    }   
    return value;
}] subscribe:channelB];//通道A流向B
//改造通道B,使通过通道B的值,如果等于"左",就改为"右"传出去
[[channelB map:^id(NSString *value) {
    if ([value isEqualToString:@"左"]) {
        return @"右";
    }
    return value;
}] subscribe:channelA];//通道B流向A
//KVO监听valueA的值得改变,过滤valueA的值,返回YES表示通过
[[RACObserve(self, valueA) filter:^BOOL(id value) {
    return value ? YES : NO;
}] subscribeNext:^(NSString* x) {
    NSLog(@"你向%@", x);
}];
//KVO监听valueB的值得改变,过滤valueB的值,返回YES表示通过
[[RACObserve(self, valueB) filter:^BOOL(id value) {
    return value ? YES : NO;
}] subscribeNext:^(NSString* x) {
    NSLog(@"他向%@", x);
}];
//下面使valueA的值和valueB的值发生改变
self.valueA = @"西";
self.valueB = @"左";
若往西,他即往东面,他于左,你尽管为右侧。
//创建2个通道,一个从A流出的通道A和一个从B流出的通道B
RACChannelTerminal *channelA = RACChannelTo(self, valueA);
RACChannelTerminal *channelB = RACChannelTo(self, valueB);
//改造通道A,使通过通道A的值,如果等于"西",就改为"东"传出去
[[channelA map:^id(NSString *value) {
    if ([value isEqualToString:@"西"]) {
        return @"东";
    }   
    return value;
}] subscribe:channelB];//通道A流向B
//改造通道B,使通过通道B的值,如果等于"左",就改为"右"传出去
[[channelB map:^id(NSString *value) {
    if ([value isEqualToString:@"左"]) {
        return @"右";
    }
    return value;
}] subscribe:channelA];//通道B流向A
//KVO监听valueA的值得改变,过滤valueA的值,返回YES表示通过
[[RACObserve(self, valueA) filter:^BOOL(id value) {
    return value ? YES : NO;
}] subscribeNext:^(NSString* x) {
    NSLog(@"你向%@", x);
}];
//KVO监听valueB的值得改变,过滤valueB的值,返回YES表示通过
[[RACObserve(self, valueB) filter:^BOOL(id value) {
    return value ? YES : NO;
}] subscribeNext:^(NSString* x) {
    NSLog(@"他向%@", x);
}];
//下面使valueA的值和valueB的值发生改变
self.valueA = @"西";
self.valueB = @"左";
协了解,我做了脚是图,①②③④凡是打印顺序:
扶助了解,我开了底是图,①②③④是打印顺序:

图片 8

4. 代理
4. 代理
汝是程序员,你帮助自己形容单app吧。
//代理定义
@protocol ProgrammerDelegate
- (void)makeAnApp;
@end
/****************************************/
//为self添加一个信号,表示代理ProgrammerDelegate的makeAnApp方法信号
RACSignal *programmerSignal = [self rac_signalForSelector:@selector(makeAnApp) 
                                             fromProtocol:@protocol(ProgrammerDelegate)];
//设置代理方法makeAnApp的实现
[programmerSignal subscribeNext:^(RACTuple* x) {
    //这里可以理解为makeAnApp的方法要的执行代码
    NSLog(@"花了一个月,app写好了");
}];
//调用代理方法
[self makeAnApp];
乃是程序员,你帮自己写单app吧。
//代理定义
@protocol ProgrammerDelegate
- (void)makeAnApp;
@end
/****************************************/
//为self添加一个信号,表示代理ProgrammerDelegate的makeAnApp方法信号
RACSignal *programmerSignal = [self rac_signalForSelector:@selector(makeAnApp) 
                                             fromProtocol:@protocol(ProgrammerDelegate)];
//设置代理方法makeAnApp的实现
[programmerSignal subscribeNext:^(RACTuple* x) {
    //这里可以理解为makeAnApp的方法要的执行代码
    NSLog(@"花了一个月,app写好了");
}];
//调用代理方法
[self makeAnApp];
5. 广播
5. 广播
知情乃的频道,我虽能听到而了。
NSNotificationCenter *center = [NSNotificationCenter defaultCenter];
//注册广播通知
RACSignal *signal = [center rac_addObserverForName:@"代码之道频道" object:nil];
//设置接收到通知的回调处理
[signal subscribeNext:^(NSNotification* x) {
    NSLog(@"技巧:%@", x.userInfo[@"技巧"]);
}];
//发送广播通知
[center postNotificationName:@"代码之道频道" 
                      object:nil 
                    userInfo:@{@"技巧":@"用心写"}];
知晓您的频道,我哪怕可知听到而了。
NSNotificationCenter *center = [NSNotificationCenter defaultCenter];
//注册广播通知
RACSignal *signal = [center rac_addObserverForName:@"代码之道频道" object:nil];
//设置接收到通知的回调处理
[signal subscribeNext:^(NSNotification* x) {
    NSLog(@"技巧:%@", x.userInfo[@"技巧"]);
}];
//发送广播通知
[center postNotificationName:@"代码之道频道" 
                      object:nil 
                    userInfo:@{@"技巧":@"用心写"}];
6. 串联

有限只无串联,一个任处理完自己的东西,下一个管才开拍卖自己的物

6. 串联

简单只无串联,一个无论处理完自己的事物,下一个不管才开拍卖好的东西

存是一个故事接一个故事。
//创建一个信号管A
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //发送一个Next玻璃球和一个Complete玻璃球
    [subscriber sendNext:@"我恋爱啦"];
    [subscriber sendCompleted];
    return nil;
}];
//创建一个信号管B
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //发送一个Next玻璃球和一个Complete玻璃球
    [subscriber sendNext:@"我结婚啦"];
    [subscriber sendCompleted];
    return nil;
}];
//串联管A和管B
RACSignal *concatSignal = [signalA concat:signalB];
//串联后的接收端处理
[concatSignal subscribeNext:^(id x) {
    NSLog(@"%@",x);
}];
//打印:我恋爱啦 我结婚啦
活着是一个故事接一个故事。
//创建一个信号管A
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //发送一个Next玻璃球和一个Complete玻璃球
    [subscriber sendNext:@"我恋爱啦"];
    [subscriber sendCompleted];
    return nil;
}];
//创建一个信号管B
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //发送一个Next玻璃球和一个Complete玻璃球
    [subscriber sendNext:@"我结婚啦"];
    [subscriber sendCompleted];
    return nil;
}];
//串联管A和管B
RACSignal *concatSignal = [signalA concat:signalB];
//串联后的接收端处理
[concatSignal subscribeNext:^(id x) {
    NSLog(@"%@",x);
}];
//打印:我恋爱啦 我结婚啦
7. 并联

片单管并联,只要发生一个不论是出东西,就用出去处理它。

7. 并联

区区个管并联,只要出一个无论来物,就以出来处理它。

污水都应有流入污水处理厂于拍卖。
//创建信号A
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"纸厂污水"];
    return nil;
}];
//创建信号B
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"电镀厂污水"];
    return nil;
}];
//并联2个信号
RACSignal *mergeSignal = [RACSignal merge:@[signalA, signalB]];
[mergeSignal subscribeNext:^(id x) {
    NSLog(@"处理%@",x);
}];
污水都应当流入污水处理厂于拍卖。
//创建信号A
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"纸厂污水"];
    return nil;
}];
//创建信号B
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"电镀厂污水"];
    return nil;
}];
//并联2个信号
RACSignal *mergeSignal = [RACSignal merge:@[signalA, signalB]];
[mergeSignal subscribeNext:^(id x) {
    NSLog(@"处理%@",x);
}];
8. 组合
//定义2个自定义信号
RACSubject *letters = [RACSubject subject];
RACSubject *numbers = [RACSubject subject];
//组合信号
[[RACSignal combineLatest:@[letters, numbers] 
                   reduce:^(NSString *letter, NSString *number){
    //把2个信号的信号值进行字符串拼接
    return [letter stringByAppendingString:number];
}] subscribeNext:^(NSString * x) {
    NSLog(@"%@", x);
}];
 //自己控制发送信号值
[letters sendNext:@"A"];
[letters sendNext:@"B"];
[numbers sendNext:@"1"];//打印B1
[letters sendNext:@"C"];//打印C1
[numbers sendNext:@"2"];//打印C2
8. 组合
//定义2个自定义信号
RACSubject *letters = [RACSubject subject];
RACSubject *numbers = [RACSubject subject];
//组合信号
[[RACSignal combineLatest:@[letters, numbers] 
                   reduce:^(NSString *letter, NSString *number){
    //把2个信号的信号值进行字符串拼接
    return [letter stringByAppendingString:number];
}] subscribeNext:^(NSString * x) {
    NSLog(@"%@", x);
}];
 //自己控制发送信号值
[letters sendNext:@"A"];
[letters sendNext:@"B"];
[numbers sendNext:@"1"];//打印B1
[letters sendNext:@"C"];//打印C1
[numbers sendNext:@"2"];//打印C2

图片 9

9. 合流压缩
9. 合流压缩
我们是吉白的
//创建信号A
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"红"];
    [subscriber sendNext:@"白"];
    return nil;
}];
//创建信号B
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"白"];
    return nil;
}];
//合流后出来的是压缩包,需要解压才能取到里面的值
[[signalA zipWith:signalB] subscribeNext:^(RACTuple* x) {
    //解压缩
    RACTupleUnpack(NSString *stringA, NSString *stringB) = x;
    NSLog(@"我们是%@%@的", stringA, stringB);
}];
//打印:我们是红白的
咱是红白之
//创建信号A
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"红"];
    [subscriber sendNext:@"白"];
    return nil;
}];
//创建信号B
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"白"];
    return nil;
}];
//合流后出来的是压缩包,需要解压才能取到里面的值
[[signalA zipWith:signalB] subscribeNext:^(RACTuple* x) {
    //解压缩
    RACTupleUnpack(NSString *stringA, NSString *stringB) = x;
    NSLog(@"我们是%@%@的", stringA, stringB);
}];
//打印:我们是红白的
10. 映射
10. 映射
自好点石成金。
//创建信号,发送"石"玻璃球
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"石"];
    return nil;
}];
//对信号进行改造,改造"石"为"金"
signal = [signal map:^id(NSString *value) {
    if ([value isEqualToString:@"石"]) {
        return @"金";
    }
    return value;
}];
//打印
[signal subscribeNext:^(id x) {
    NSLog(@"%@", x);//金
}];
自己好点石成金。
//创建信号,发送"石"玻璃球
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@"石"];
    return nil;
}];
//对信号进行改造,改造"石"为"金"
signal = [signal map:^id(NSString *value) {
    if ([value isEqualToString:@"石"]) {
        return @"金";
    }
    return value;
}];
//打印
[signal subscribeNext:^(id x) {
    NSLog(@"%@", x);//金
}];
11. 过滤
11. 过滤
非满十八东,禁止登。
//创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@(15)];
    [subscriber sendNext:@(17)];
    [subscriber sendNext:@(21)];
    [subscriber sendNext:@(14)];
    [subscriber sendNext:@(30)];
    return nil;
}]
//过滤信号,并打印
[[signal filter:^BOOL(NSNumber* value) {
    //值大于等于18的才能通过过滤网
    return value.integerValue >= 18;
}] subscribeNext:^(id x) {
    NSLog(@"%@", x);
}];
//打印:21 30
匪满十八寒暑,禁止入。
//创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    [subscriber sendNext:@(15)];
    [subscriber sendNext:@(17)];
    [subscriber sendNext:@(21)];
    [subscriber sendNext:@(14)];
    [subscriber sendNext:@(30)];
    return nil;
}]
//过滤信号,并打印
[[signal filter:^BOOL(NSNumber* value) {
    //值大于等于18的才能通过过滤网
    return value.integerValue >= 18;
}] subscribeNext:^(id x) {
    NSLog(@"%@", x);
}];
//打印:21 30
12. 秩序(flattenMap方法吧可变成then方法,效果等同)
12. 秩序(flattenMap方法吗得以变换成then方法,效果等同)
打蛋液,煎鸡蛋,上盘。
//创建一个信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    NSLog(@"打蛋液");
    [subscriber sendNext:@"蛋液"];
    [subscriber sendCompleted];
    return nil;
}]
//对信号进行秩序执行第一步
signal = [signal flattenMap:^RACStream *(NSString* value) {
    //处理上一步的RACSignal的信号值value,这里value = @"蛋液"
    NSLog(@"把%@倒进锅里面煎",value);
    //返回下一步的RACSignal信号
    return [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"煎蛋"];
        [subscriber sendCompleted];
        return nil;
    }];
}];
//对信号进行秩序执行第二步
signal = [signal flattenMap:^RACStream *(NSString* value) {
    //处理上一步的RACSignal的信号值value,这里value = @"煎蛋"
    NSLog(@"把%@装到盘里", value);
    //返回下一步的RACSignal信号
    return [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"上菜"];
        [subscriber sendCompleted];
        return nil;
    }];
}];
//最后打印
[signal subscribeNext:^(id x) {
    NSLog(@"%@", x);
}];
/* 
打印:
    打蛋液  
    把蛋液倒进锅里面煎  
    把煎蛋装到盘里  
    上菜
*/
打蛋液,煎鸡蛋,上盘。
//创建一个信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    NSLog(@"打蛋液");
    [subscriber sendNext:@"蛋液"];
    [subscriber sendCompleted];
    return nil;
}]
//对信号进行秩序执行第一步
signal = [signal flattenMap:^RACStream *(NSString* value) {
    //处理上一步的RACSignal的信号值value,这里value = @"蛋液"
    NSLog(@"把%@倒进锅里面煎",value);
    //返回下一步的RACSignal信号
    return [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"煎蛋"];
        [subscriber sendCompleted];
        return nil;
    }];
}];
//对信号进行秩序执行第二步
signal = [signal flattenMap:^RACStream *(NSString* value) {
    //处理上一步的RACSignal的信号值value,这里value = @"煎蛋"
    NSLog(@"把%@装到盘里", value);
    //返回下一步的RACSignal信号
    return [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"上菜"];
        [subscriber sendCompleted];
        return nil;
    }];
}];
//最后打印
[signal subscribeNext:^(id x) {
    NSLog(@"%@", x);
}];
/* 
打印:
    打蛋液  
    把蛋液倒进锅里面煎  
    把煎蛋装到盘里  
    上菜
*/
13. 命令
13. 命令
自己命你立即投降。
//创建命令
RACCommand *aCommand = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(NSString *input) {
    //命令执行代码
    NSLog(@"%@我投降了",input);
    //返回一个RACSignal信号
    return [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendCompleted];
        return nil;
    }];
}];
//执行命令
[aCommand execute:@"今天"];
//打印:今天我投降了
自身命你顿时投降。
//创建命令
RACCommand *aCommand = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(NSString *input) {
    //命令执行代码
    NSLog(@"%@我投降了",input);
    //返回一个RACSignal信号
    return [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendCompleted];
        return nil;
    }];
}];
//执行命令
[aCommand execute:@"今天"];
//打印:今天我投降了
14. 延迟
14. 延迟
等等我,我还有10秒钟就到了。
//创建一个信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    NSLog(@"等等我,我还有10秒钟就到了");
    [subscriber sendNext:@"车陂南"];
    [subscriber sendCompleted];
    return nil;
}];
//延时10秒接受Next玻璃球
[[RACSignal delay:10] subscribeNext:^(NSString *x) {
    NSLog(@"我到了%@",x);
}];
/*
[2016-04-21 13:20:10]等等我,我还有10秒钟就到了
[2016-04-21 13:20:20]我到了车陂南
*/
等等我,我还有10秒钟就交了。
//创建一个信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    NSLog(@"等等我,我还有10秒钟就到了");
    [subscriber sendNext:@"车陂南"];
    [subscriber sendCompleted];
    return nil;
}];
//延时10秒接受Next玻璃球
[[RACSignal delay:10] subscribeNext:^(NSString *x) {
    NSLog(@"我到了%@",x);
}];
/*
[2016-04-21 13:20:10]等等我,我还有10秒钟就到了
[2016-04-21 13:20:20]我到了车陂南
*/
15. 重放
15. 重放
同等差制造,多次视。
//创建一个普通信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    NSLog(@"大导演拍了一部电影《我的男票是程序员》");
    [subscriber sendNext:@"《我的男票是程序员》"];
    return nil;
}];
//创建该普通信号的重复信号
RACSignal *replaySignal = [signal replay];
//重复接受信号
[replaySignal subscribeNext:^(NSString *x) {
    NSLog(@"小明看了%@", x);
}];
[replaySignal subscribeNext:^(NSString *x) {
    NSLog(@"小红也看了%@", x);
}];
/*
大导演拍了一部电影《我的男票是程序员》
小明看了《我的男票是程序员》
小红也看了《我的男票是程序员》
*/
平等次打,多次观。
//创建一个普通信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    NSLog(@"大导演拍了一部电影《我的男票是程序员》");
    [subscriber sendNext:@"《我的男票是程序员》"];
    return nil;
}];
//创建该普通信号的重复信号
RACSignal *replaySignal = [signal replay];
//重复接受信号
[replaySignal subscribeNext:^(NSString *x) {
    NSLog(@"小明看了%@", x);
}];
[replaySignal subscribeNext:^(NSString *x) {
    NSLog(@"小红也看了%@", x);
}];
/*
大导演拍了一部电影《我的男票是程序员》
小明看了《我的男票是程序员》
小红也看了《我的男票是程序员》
*/
16. 定时
16. 定时
诸隔8独小时服一破药。
//创建定时器信号,定时8个小时
RACSignal *signal = [RACSignal interval:60*60*8 
                            onScheduler:[RACScheduler mainThreadScheduler]];
//定时执行代码
[signal subscribeNext:^(id x) {
    NSLog(@"吃药");
}];
各国隔8单小时服一糟药。
//创建定时器信号,定时8个小时
RACSignal *signal = [RACSignal interval:60*60*8 
                            onScheduler:[RACScheduler mainThreadScheduler]];
//定时执行代码
[signal subscribeNext:^(id x) {
    NSLog(@"吃药");
}];
17. 超时
17. 超时
当了卿一个钟头了,你还没有来,我运动了。
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //创建发送信息信号
    NSLog(@"我快到了");
    RACSignal *sendSignal = [RACSignal createSignal:^RACDisposable *(id sendSubscriber) {
        [sendSubscriber sendNext:nil];
        [sendSubscriber sendCompleted];
        return nil;
    }];
    //发送信息要1个小时10分钟才到
    [[sendSignal delay:60*70] subscribeNext:^(id x) {
        //这里才发送Next玻璃球到signal
        [subscriber sendNext:@"我到了"];
        [subscriber sendCompleted];
    }];
    return nil;
}]
//这里对signal进行超时接受处理,如果1个小时都没收到玻璃球,超时错误
[[signal timeout:60*60 
     onScheduler:[RACScheduler mainThreadScheduler]] 
  subscribeError:^(NSError *error)
{
    //超时错误处理
    NSLog(@"等了你一个小时了,你还没来,我走了");
}];
齐了您一个钟头了,你还不曾来,我倒了。
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //创建发送信息信号
    NSLog(@"我快到了");
    RACSignal *sendSignal = [RACSignal createSignal:^RACDisposable *(id sendSubscriber) {
        [sendSubscriber sendNext:nil];
        [sendSubscriber sendCompleted];
        return nil;
    }];
    //发送信息要1个小时10分钟才到
    [[sendSignal delay:60*70] subscribeNext:^(id x) {
        //这里才发送Next玻璃球到signal
        [subscriber sendNext:@"我到了"];
        [subscriber sendCompleted];
    }];
    return nil;
}]
//这里对signal进行超时接受处理,如果1个小时都没收到玻璃球,超时错误
[[signal timeout:60*60 
     onScheduler:[RACScheduler mainThreadScheduler]] 
  subscribeError:^(NSError *error)
{
    //超时错误处理
    NSLog(@"等了你一个小时了,你还没来,我走了");
}];
18. 重试
18. 重试
得逞之前可能需要数百蹩脚破产。
__block int failedCount = 0;
//创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    if (failedCount < 100) {
        failedCount++;
        NSLog(@"我失败了");
        //发送错误,才会要重试
        [subscriber sendError:nil];
    } else {
        NSLog(@"经历了数百次失败后");
        [subscriber sendNext:nil];
    }
    return nil;
}];
//重试
RACSignal *retrySignal = [signal retry];
//直到发送了Next玻璃球
[retrySignal subscribeNext:^(id x) {
    NSLog(@"终于成功了");
}];
马到成功之前可能用数百次等失败。
__block int failedCount = 0;
//创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    if (failedCount < 100) {
        failedCount++;
        NSLog(@"我失败了");
        //发送错误,才会要重试
        [subscriber sendError:nil];
    } else {
        NSLog(@"经历了数百次失败后");
        [subscriber sendNext:nil];
    }
    return nil;
}];
//重试
RACSignal *retrySignal = [signal retry];
//直到发送了Next玻璃球
[retrySignal subscribeNext:^(id x) {
    NSLog(@"终于成功了");
}];
19. 节流
19. 节流
腼腆,这里一秒钟就能够通过一个口。
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //即时发送一个Next玻璃球
    [subscriber sendNext:@"旅客A"];
    //下面是GCD延时发送Next玻璃球
    dispatch_queue_t mainQueue = dispatch_get_main_queue();
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(1 * NSEC_PER_SEC)),mainQueue, ^{
        [subscriber sendNext:@"旅客B"];
    });
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(2 * NSEC_PER_SEC)),mainQueue, ^{
        //发送多个Next,如果节流了,接收最新发送的
        [subscriber sendNext:@"旅客C"];
        [subscriber sendNext:@"旅客D"];
        [subscriber sendNext:@"旅客E"];
    });
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(3 * NSEC_PER_SEC)),mainQueue, ^{
        [subscriber sendNext:@"旅客F"];
    });
    return nil;
}];
//对信号进行节流,限制短时间内一次只能接收一个Next玻璃球
[[signal throttle:1] subscribeNext:^(id x) {
    NSLog(@"%@通过了",x);
}];
/*
[2015-08-16 22:08:45.677]旅客A  
[2015-08-16 22:08:46.737]旅客B  
[2015-08-16 22:08:47.822]旅客E  
[2015-08-16 22:08:48.920]旅客F
*/
腼腆,这里一秒钟才会由此一个人数。
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //即时发送一个Next玻璃球
    [subscriber sendNext:@"旅客A"];
    //下面是GCD延时发送Next玻璃球
    dispatch_queue_t mainQueue = dispatch_get_main_queue();
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(1 * NSEC_PER_SEC)),mainQueue, ^{
        [subscriber sendNext:@"旅客B"];
    });
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(2 * NSEC_PER_SEC)),mainQueue, ^{
        //发送多个Next,如果节流了,接收最新发送的
        [subscriber sendNext:@"旅客C"];
        [subscriber sendNext:@"旅客D"];
        [subscriber sendNext:@"旅客E"];
    });
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(3 * NSEC_PER_SEC)),mainQueue, ^{
        [subscriber sendNext:@"旅客F"];
    });
    return nil;
}];
//对信号进行节流,限制短时间内一次只能接收一个Next玻璃球
[[signal throttle:1] subscribeNext:^(id x) {
    NSLog(@"%@通过了",x);
}];
/*
[2015-08-16 22:08:45.677]旅客A  
[2015-08-16 22:08:46.737]旅客B  
[2015-08-16 22:08:47.822]旅客E  
[2015-08-16 22:08:48.920]旅客F
*/
20. 极(takeUntil方法:当给定的signal完成前直接取值)
20. 规范(takeUntil方法:当给定的signal完成前一直取值)
以至世界之边才会把我们分手。
//创建取值信号
RACSignal *takeSignal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //创建一个定时器信号,每隔1秒触发一次
    RACSignal *signal = [RACSignal interval:1 
                                onScheduler:[RACScheduler mainThreadScheduler]];
    //定时接收
    [signal subscribeNext:^(id x) {
        //在这里定时发送Next玻璃球
        [subscriber sendNext:@"直到世界的尽头才能把我们分开"];
    }];
    return nil;
}];
//创建条件信号
RACSignal *conditionSignal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //设置5秒后发生Complete玻璃球
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, 
          (int64_t)(5 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        NSLog(@"世界的尽头到了");
        [subscriber sendCompleted];
    });
    return nil;
}]
//设置条件,takeSignal信号在conditionSignal信号接收完成前,不断地取值
[[takeSignal takeUntil:conditionSignal] subscribeNext:^(id x) {
    NSLog(@"%@", x);
}];
/*
[2015-08-16 22:17:22.648]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:23.648]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:24.645]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:25.648]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:26.644]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:26.645]世界的尽头到了
*/

RAC还起更多之动,目前就是学习到这些,大部分职能基本已入我们的付出要求了,就整治分享下。

以至于世界之界限才能够把我们分手。
//创建取值信号
RACSignal *takeSignal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //创建一个定时器信号,每隔1秒触发一次
    RACSignal *signal = [RACSignal interval:1 
                                onScheduler:[RACScheduler mainThreadScheduler]];
    //定时接收
    [signal subscribeNext:^(id x) {
        //在这里定时发送Next玻璃球
        [subscriber sendNext:@"直到世界的尽头才能把我们分开"];
    }];
    return nil;
}];
//创建条件信号
RACSignal *conditionSignal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
    //设置5秒后发生Complete玻璃球
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, 
          (int64_t)(5 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        NSLog(@"世界的尽头到了");
        [subscriber sendCompleted];
    });
    return nil;
}]
//设置条件,takeSignal信号在conditionSignal信号接收完成前,不断地取值
[[takeSignal takeUntil:conditionSignal] subscribeNext:^(id x) {
    NSLog(@"%@", x);
}];
/*
[2015-08-16 22:17:22.648]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:23.648]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:24.645]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:25.648]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:26.644]直到世界的尽头才能把我们分开  
[2015-08-16 22:17:26.645]世界的尽头到了
*/

RAC还生重多之运用,目前就算学习到这些,大部分效应核心已入我们的付出要求了,就打点分享下。

图片 10

如果有什么问题在下方评论区中提出!O(∩_∩)O哈!
假若发啊问题在江湖评论区中提出!O(∩_∩)O哈!

相关文章