RAC的基本使用一

2018-08-19  本文已影响1人  heart_领

一、函数介绍:
(a) flatten Map:在bind基础上封装的改变方法,用自己提供的 block,改变当前流,变成 block返回的流对象。
(b) flatten:在 flattenmap基础封装的改变方法,如果当前反应流中的对象也是一个流的话,就可以将当前流变成当前流中的流对象
(c)map:在 lattenmap基础上封装的改变方法,在flattenmap中的 block中返回的值必须也是流对象,而map则不需要,它是将流中的对象执行 block后,用流的 return方法将值变成流对象。
(d) mapreplace:在map的基础上封装的改变方法,直接替換当前流中的对象,形成一个新的对象流。
(e) filter:在Map基础上封装的改变封装,过滤掉当前流中不符合要求的对象,将之变为空流
(f) Ignore:在ter基础封装的改变方法,忽略和当前值一样的对象,将之变为空流
(g)skip:在bind基础上封装的改变方法,忽略当前流前η次的对象值,将之变为空流
(h) take:在bind基础上封装的改变方法,只区当前流中的前n次对象值,之后将流变为空(不是空流)。
(i) distinctuntilchanged:在bind基础封装的改变方法,当流中后一次的值和前一次的值不同的时候才会返回当前值的流,否则返回空流(第一次默认被怱略)
(j) takeuntilblock:在bind基础封装的改变方法,取当前流的对象值,直到当前值满足提供的 block,就会将当前流变为空(不是空流)
(k) takewhileblock:在bind基础封装的改变方法,取当前流的对象值,直到当前值不满足提供的 block,就会将当前流变为空(不是空流)
(l) skipuntilblock:在bind基础封装的改变方法,忽略当前流的对象值(变为空流),直到当前值满足提供的block。
(m) skipwhileblock:在bind基础封装的改变方法,忽略当前流的对象值(变为空流),直到当前值不满足提供的block
(n) scanWithstart: reducewithlndex:在bind基础封装的改变方法,用同样的 block执行每次流中的值,并将结果用于后一次执行当中,每次都把 block执行后的值变成新的流中的对象。
(o) startwith:在 contact基础上封装的多流之间的顺序方法,在当前流的值流出之前,加入一个初始值
(p)zip:打包多流,将多个流中的值包装成一个RACTuple对象
(q) reduceeach:将流中的 RACTuple对象进行过滤,返回特定的衍生出的一个值对象

二函数使用
1.创建信号

//1:创建信号
        RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            //subscriber 对象不是一个对象
            //3:发送信号
            [subscriber sendNext:@"开心每一天"];
            //请求网络 失败 error
            NSError *error = [NSError errorWithDomain:NSURLErrorDomain code:10086 userInfo:@{@"key":@"10086错误"}];
            [subscriber sendError:error];
//            [subscriber sendCompleted];
//            [RACSignal empty];
            //RACDisposable 销毁
            return [RACDisposable disposableWithBlock:^{//订阅一次销毁一次,订阅几次销毁几次
                NSLog(@"销毁了");
            }];
        }];
        //2:订阅信号
        [signal subscribeNext:^(id  _Nullable x) {
            NSLog(@"111%@",x);
        } error:^(NSError * _Nullable error) {
            NSLog(@"222%@",error);
        }];

2.替代KVO

[RACObserve(self, name) subscribeNext:^(id  _Nullable x) {
            NSLog(@"哈哈哈哈哈:%@",x);
        }];

3.替代代理

[[self rac_signalForSelector:@selector(textFieldDidBeginEditing:) fromProtocol:@protocol(UITextFieldDelegate)] subscribeNext:^(RACTuple * _Nullable x) {

            NSLog(@"hhhh:%@****%@",x.first,x.second);
        }];
        self.textField.delegate = self;

//监听textField的内容
[self.textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
            NSLog(@"%@",x);
        }];

4.替代通知

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

5.替代UI target

//UIButton
[[self.button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
            NSLog(@"点击button:%@",x);
        }];

//UITapGestureRecognizer
UITapGestureRecognizer *tap = [[UITapGestureRecognizer alloc] init];
        self.label.userInteractionEnabled = YES;
        [self.label addGestureRecognizer:tap];
        [tap.rac_gestureSignal subscribeNext:^(__kindof UIGestureRecognizer * _Nullable x) {
            NSLog(@"kkkkk:%@",x);
        }];

6.RACCommand的使用

RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal * _Nonnull(id  _Nullable input) {
            NSLog(@"传入的值:%@",input);//输出:开心每一天
//            return [RACSignal return:@"天气很好"];
            return [RACSignal error:[NSError errorWithDomain:NSURLErrorDomain code:10086 userInfo:@{@"key":@"10086错误"}]];
        }];
//        方式一
//        [[command.executionSignals concat] subscribeNext:^(id  _Nullable x) {
//            NSLog(@"button的内容:%@",x);//输出:天气很好
//        }];
//        方式二
        [command.executionSignals.switchToLatest subscribeNext:^(id  _Nullable x) {
            
            NSLog(@"button的内容:%@",x);//输出:天气很好
        }];
        [command.executing subscribeNext:^(NSNumber * _Nullable x) {
            NSLog(@"hhhhhhh:%@",x);//x
//            x为1信号内容正在返回,为0信号内容已经返回
            if ([x boolValue]) {//显示加载
                
            }else{//隐藏加载
                
            }
        }];
        [command.errors subscribeNext:^(NSError * _Nullable x) {
            NSLog(@"错误信息%@",x);//错误信息Error Domain=NSURLErrorDomain Code=10086 "(null)" UserInfo={key=10086错误}
        }];
        [command execute:@"开心每一天"];//执行

//UIButton使用RACCommand
self.button.rac_command = [[RACCommand alloc] initWithSignalBlock:^RACSignal * _Nonnull(id  _Nullable input) {//点击button就会执行该block中的代码
            NSLog(@"传入的值:%@",input);//输出:button
            return [RACSignal return:@"天气很好"];
        }];

7.数据结构

//数组
        NSArray *array = @[@"Cooci",@"123",@"18"];
        [array.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
            NSLog(@"%@",x);
        }];
        NSDictionary *dict = @{@"key":@"Cooci",@"age":@"18",@"gender":@"1"};
        [dict.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
           //元祖
            NSLog(@"%@",x);
            RACTwoTuple *tuple = (RACTwoTuple *)x;
            NSLog(@"key == %@ , value = %@",tuple[0],tuple[1]);
        }];

8.代替timer(定时器)


__block int num = 0;
    RACSignal *signal = [[[RACSignal interval:1 onScheduler:[RACScheduler mainThreadScheduler]] map:^id _Nullable(NSDate * _Nullable value) {
        num += 1;
        return @(num);
    }] takeUntilBlock:^BOOL(id  _Nullable x) {
        if ([x integerValue]>6) {
            return YES;
        }
        NSLog(@"数字:%@",x);
        return NO;
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"订阅到的内容:%@",x);
    }];

RACDisposable *dispo = [[RACSignal interval:1 onScheduler:[RACScheduler schedulerWithPriority:(RACSchedulerPriorityHigh) name:@" com.ReactiveCocoa.RACScheduler.mainThreadScheduler"]] subscribeNext:^(NSDate * _Nullable x) {
//           x为当前时间:Sun Aug 19 15:08:35 2018
            NSLog(@"线程:%@",[NSThread currentThread]);
          num--;
        }];
        while (1) {
            if (num<=0) {
               [dispo dispose];
            }
        }
  1. merge
// merge:把多个信号合并成一个信号
    //创建多个信号
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button  rac_signalForControlEvents:UIControlEventTouchUpInside];
    // 合并信号,任何一个信号发送数据,都能监听到.
    RACSignal *mergeSignal = [signalA merge:signalB];
    [mergeSignal subscribeNext:^(id x) {
        NSLog(@"%@",x);//signalA发送数据,x就为signalA发送的内容,signalB发送数据,x就为signalB发送的内容
    }];

10.zipWith,记录每一次信号

// 底层实现:
    // 1.定义压缩信号,内部就会自动订阅signalA,signalB
    // 2.每当signalA或者signalB发出信号,就会判断signalA,signalB有没有发出个信号,有就会把最近发出的信号都包装成元组发出。
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button  rac_signalForControlEvents:UIControlEventTouchUpInside];
    //保存每一次的信号,
    /**
     假如signalA先发送了两次,此时signalB没有发送,则zipSignal不会触发即订阅不到内容。
     此时signalB最多发送两次,第三次zipSignal不会触发即订阅不到内容,signalB发送内容,触发zipSignal受signalA发送次数的限制。假如signalB发送一次,此时zipSignal触发,signalA再发送一次,此时zipSignal不会触发,signalB此时发送第二次和第三次都能触发zipSignal(因为signalA共发送了三次),signalB发送三次完之后,signalB发送第四次和第五次,则不会触发zipSignal,此时再让signalA发送第四次,第五次则触发 zipSignal,第六次不会触发zipSignal,要想触发zipSignal则让signalB发送六次。以此类推
     */
    RACSignal *zipSignal = [signalA zipWith:signalB];
    [zipSignal subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

11.combineLatestWith,记录最后一次的信号

//将多个信号合并起来,并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext,才会触发合并的信号。只有其中一个信号有过sendNext,则不会触发合并的信号,两个信号都至少都有过一次sendNext后,任意一个信号sendNext,都会触发合并信号
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button  rac_signalForControlEvents:UIControlEventTouchUpInside];
    // 合并信号,任何一个信号发送数据,都能监听到.
    RACSignal *comSignal = [signalA combineLatestWith:signalB];
    [comSignal subscribeNext:^(id x) {
        NSLog(@"%@",x);//x为RACTwoTuple,第一个值为第一个信号的最新内容,第二个值为第二个信号的最新内容
    }];
    // 底层实现:
    // 1.当组合信号被订阅,内部会自动订阅signalA,signalB,必须两个信号都发出内容,才会被触发。
    // 2.并且把两个信号组合成元组发出。
    //区别于zipWith  zipWith两个信号都要有记录,如果记录的信号触发过了 就不在触发
    //zipWith 记录每一次信号  combineLatestWith记录最后一次的信号
  1. then
//下一个网络请求。依赖上一个网络请求
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"开心每一天"];
        [subscriber sendCompleted];//必须加上才能执行then中的代码
        return nil;
    }] then:^RACSignal * _Nonnull{
        return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            
            [subscriber sendNext:@"Gavin"];
            [subscriber sendCompleted];
            return nil;
        }];  
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);//输出Gavin(输出第二个信号中的内容)
    }];
  1. retry ,只要失败,就会重新执行创建信号中的block,直到成功
//retry重试 :只要失败,就会重新执行创建信号中的block,直到成功.
        __block int i = 0;
        [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            if (i == 10) {
                [subscriber sendNext:@1];
            }else{
                NSLog(@"接收到错误");
                [subscriber sendError:nil];//只有发送错误(sendError),retry才能起作用,进行第二次,第三次...的发送,直到sendNext,才会终结
            }
            i++;
            return nil;
        }] retry] subscribeNext:^(id x) {
            NSLog(@"接收到的信息:%@",x);
        } error:^(NSError *error) {
            NSLog(@"发生错误");
        }];

14.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);
    }];
  1. timeout
RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
//        [subscriber sendNext:@"开心每一天"];
        [subscriber sendError:@"111"];
        return nil;
    }] timeout:10 onScheduler:[RACScheduler currentScheduler]];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"接收到的信息:%@",x);
    } error:^(NSError * _Nullable error) {
        NSLog(@"错误信息:%@",error);//超过10秒或者发送错误,就会打印错误信息,
        
    }];

16.switchToLatest

RACSubject *signalOfSignals = [RACSubject subject];
    RACSubject *signal = [RACSubject subject];
    // 获取信号中信号最近发出信号,订阅最近发出的信号。
    // 注意switchToLatest:只能用于信号中的信号
    [signalOfSignals.switchToLatest subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];
//    [[signalOfSignals concat] subscribeNext:^(id  _Nullable x) {
//        NSLog(@"%@",x);
//    }];
    [signalOfSignals sendNext:signal];
    [signal sendNext:@1];

17.takeUntil:---给takeUntil传的是哪个信号(subject2),那么当这个信号发送信号或sendCompleted,就不能再接受源信号(subject)的内容了。

RACSubject *subject = [RACSubject subject];
    RACSubject *subject2 = [RACSubject subject];
    [[subject takeUntil:subject2] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 发送信号
    [subject sendNext:@1];
    [subject sendNext:@2];
//        [subject2 sendNext:@3];  // 1
//        [subject2 sendCompleted]; // 或2
    [subject sendNext:@4];

18.takeLast:和take的用法一样,不过他取的是最后的几个值,如下,则取的是最后两个值

RACSubject *subject = [RACSubject subject];
    [[subject takeLast:2] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 发送信号
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];
    [subject sendCompleted];
注意点:takeLast 一定要调用sendCompleted,告诉他发送完成了,这样才能取到最后的几个值

19.take:可以屏蔽一些值,去前面几个值---这里take为2 则只拿到前两个值

RACSubject *subject = [RACSubject subject];
    [[subject take:2] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 发送信号
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];

20.skip:表示输入第一次,不会被监听到,跳过第一次发出的信号

[[self.textField.rac_textSignal skip:1] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

21.distinctUntilChanged:当上一次的值和当前的值有明显的变化就会发出信号,否则会被忽略掉。在开发中,刷新UI经常使用,只有两次数据不一样才需要刷新

RACSubject *subject = [RACSubject subject];
    [[subject distinctUntilChanged] subscribeNext:^(id x) {
        NSLog(@"%@", x);//打印1和2
    }];
    // 发送信号
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@2];
  1. ignore:内部调用filter过滤,忽略掉ignore的值
    [[self.textField.rac_textSignal ignore:@"c"] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);//textField的内容为c则不打印
    }];

23.filter:过滤信号,使用它可以获取满足条件的信号.

// 过滤:
    // 每次信号发出,会先执行过滤条件判断.
    RACSignal *signal = [self.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        
        if (self.textField.text.length>6) {
            self.textField.text = [self.textField.text substringToIndex:6];
        }
        
        NSLog(@"value == %@",value);
        return value.length<6;
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        self.textField.text = x;
        
        NSLog(@"x== %@",x);
    }];

24.combineLatest:reduce:

//reduce`聚合:用于信号发出的内容是元组,把信号发出元组的值聚合成一个值
    //其中Aggregation(聚合关系)、Composition(合成关系)属于Association(关联关系),是特殊的Association关联关系。
    //可以延伸组合关系,聚合关系
    //组合关系 A-B组合成了C C包含所有的A和B
    //聚合关系 聚合关系是整体和个体的关系(是强的关联关系) 公司与个人,但是个人不完全属于公司
    
    // 聚合 // 常见的用法,(先组合在聚合)。combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock
    // reduce中的block简介:
    // reduceblcok中的参数,有多少信号组合,reduceblcok就有多少参数,每个参数就是之前信号发出的内容
    // reduceblcok的返回值:聚合信号之后的内容。
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button  rac_signalForControlEvents:UIControlEventTouchUpInside];
    
    RACSignal *reduceSignal = [RACSignal combineLatest:@[signalA,signalB] reduce:^(id value1, id value2){
        
        return [NSString stringWithFormat:@"reduce == %@ %@",value1,value2];
    }];
    
    [reduceSignal subscribeNext:^(id  _Nullable x) {//任何一个信号发送,都能订阅到
        
        NSLog(@"subscribeNext == %@",x);
    }];
    // 1.订阅聚合信号,每次有内容发出,就会执行reduceblcok,把信号内容转换成reduceblcok返回的值。
  1. concat,先用signalA的内容,再用signalB的内容
RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"Cooci"];
        [subscriber sendCompleted];//只有发送完成,signalB才能发送,类似于then
        return nil;
    }];
    
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"Gavin"];
        [subscriber sendCompleted];
        
        return nil;
        
    }];
    //信号signalA发送完成,signalB才能发送
    RACSignal *contactSignal = [signalA concat:signalB];
    [contactSignal subscribeNext:^(id  _Nullable x) {
        
        NSLog(@"%@",x);//signalA发送时,x为signalA的内容,signalB发送时,x为signalB的内容,类似于merge
    }];

26.bind
// 方式二:在返回结果前,拼接,使用RAC中bind方法做处理。
// bind方法参数:需要传入一个返回值是RACStreamBindBlock的block参数
// RACStreamBindBlock是一个block的类型,返回值是信号,参数(value,stop),因此参数的block返回值也是一个block。
// RACStreamBindBlock:
// 参数一(value):表示接收到信号的原始值,还没做处理
// 参数二(stop):用来控制绑定Block,如果stop = yes,那么就会结束绑定。
// 返回值:信号,做好处理,在通过这个信号返回出去,一般使用RACReturnSignal,需要手动导入头文件RACReturnSignal.h。

// bind方法使用步骤:
// 1.传入一个返回值RACStreamBindBlock的block。
// 2.描述一个RACStreamBindBlock类型的bindBlock作为block的返回值。
// 3.描述一个返回结果的信号,作为bindBlock的返回值。

// 注意:在bindBlock中做信号结果的处理。
// 底层实现:
// 1.源信号调用bind,会重新创建一个绑定信号。
// 2.当绑定信号被订阅,就会调用绑定信号中的didSubscribe,生成一个bindingBlock。
// 3.当源信号有内容发出,就会把内容传递到bindingBlock处理,调用bindingBlock(value,stop)
// 4.调用bindingBlock(value,stop),会返回一个内容处理完成的信号(RACReturnSignal)。
// 5.订阅RACReturnSignal,就会拿到绑定信号的订阅者,把处理完成的信号内容发送出来。

// 注意:不同订阅者,保存不同的nextBlock,看源码的时候,一定要看清楚订阅者是哪个。
// 这里需要手动导入#import <ReactiveCocoa/RACReturnSignal.h>,才能使用RACReturnSignal。
[[self.textField.rac_textSignal bind:^RACSignalBindBlock _Nonnull{
        
        return ^RACSignal * (NSString * _Nullable value, BOOL *stop) {
//            value为 textField中的内容
            NSLog(@"stop中值:%d",*stop);
            if (value.length>6) {//当长度大于6时,将不会再订阅到
                *stop = YES;
            }
            return [RACReturnSignal return:[NSString stringWithFormat:@"输出:%@",value]];
        };
        
    }] subscribeNext:^(id  _Nullable x) {
        
        NSLog(@"subscribeNext == %@",x);
    }];

// flattenMap作用:把源信号的内容映射成一个新的信号,信号可以是任意类型。

// flattenMap使用步骤:
// 1.传入一个block,block类型是返回值RACStream,参数value
// 2.参数value就是源信号的内容,拿到源信号的内容做处理
// 3.包装成RACReturnSignal信号,返回出去。

// flattenMap底层实现:
// 0.flattenMap内部调用bind方法实现的,flattenMap中block的返回值,会作为bind中bindBlock的返回值。
// 1.当订阅绑定信号,就会生成bindBlock。
// 2.当源信号发送内容,就会调用bindBlock(value, *stop)
// 3.调用bindBlock,内部就会调用flattenMap的block,flattenMap的block作用:就是把处理好的数据包装成信号。
// 4.返回的信号最终会作为bindBlock中的返回信号,当做bindBlock的返回信号。
// 5.订阅bindBlock的返回信号,就会拿到绑定信号的订阅者,把处理完成的信号内容发送出来。
[[self.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        return YES;
    }] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"filter == %@",x);//x为textField中的内容
    }];
    
    [[self.textField.rac_textSignal map:^id _Nullable(NSString * _Nullable value) {
        return nil;
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"map == %@",x);//x为nil
    }];

[[self.textField.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {

        NSLog(@"%@",value);

        return [RACReturnSignal return:[NSString stringWithFormat:@"输出:%@",value]];

    }] subscribeNext:^(id  _Nullable x) {

        NSLog(@"flattenMap == %@",x);

    }];
// 创建信号
    self.signal11 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        // block调用时刻:每当有订阅者订阅信号,就会调用block。
        [subscriber sendNext:@"Cooci"];
        // 如果不在发送数据,最好发送信号完成,内部会自动调用[RACDisposable disposable]取消订阅信号。
                [subscriber sendCompleted];
        NSLog(@"subscriber == %@",subscriber);
        
        RACDisposable *disposable = [RACDisposable disposableWithBlock:^{
            // 销毁信号
            // block调用时刻:当信号发送完成或者发送错误,就会自动执行这个block,取消订阅信号。
            // 执行完Block后,当前信号就不在被订阅了。
            NSLog(@"开始销毁");
        }];
        
        return disposable;
        
    }];
    
    // 订阅信号,才会激活信号.
    [self.signal11 subscribeNext:^(id  _Nullable x) {
        
        NSLog(@"x == %@",x);
    }];
[[RACSignal interval:1 onScheduler:[RACScheduler scheduler]] subscribeNext:^(NSDate * _Nullable x) {
        
        NSLog(@"%@",[NSThread currentThread]);
        
    }];

30.publish,发送一次,多次订阅到

RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        NSLog(@"今天天气很好");
        [subscriber sendNext:@"开心每一天"];
        return [RACDisposable disposableWithBlock:^{
            
            NSLog(@"销毁");
        }];
    }];
  RACMulticastConnection *connect = [signal publish];

    [connect.signal subscribeNext:^(id  _Nullable x) {
        
        NSLog(@"********:%@",x);
    }];
    
    [connect.signal subscribeNext:^(id  _Nullable x) {
        
        NSLog(@"$$$$$$$:%@",x);
    }];
    [connect connect];
    /**
     输出:
     2018-08-19 22:24:14.159839+0800 001---RAC初探[60879:4084162] 今天天气很好
     2018-08-19 22:24:14.160132+0800 001---RAC初探[60879:4084162] ********:开心每一天
     2018-08-19 22:24:14.160351+0800 001---RAC初探[60879:4084162] $$$$$$$:开心每一天
     2018-08-19 22:24:14.170105+0800 001---RAC初探[60879:4084162] 销毁

     */
上一篇 下一篇

猜你喜欢

热点阅读