ReactiveCocoa進階篇

1.rac_liftSelector:withSignals(相當于異步隊列組)

{
    /**<1.創(chuàng)建信號1*/
    RACSignal *signal01 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        /**<4.發(fā)送信號1*/
        [subscriber sendNext:@"發(fā)送數(shù)據(jù)1"];
        return  nil;
    }];
    /**<2.創(chuàng)建信號2*/
    RACSignal *signal02 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        /**<5.發(fā)送信號2*/
        [subscriber sendNext:@"發(fā)送數(shù)據(jù)2"];
        return  nil;
    }];
    /**<3.加入到隊列組中*/
    [self rac_liftSelector:@selector(sendMessageWithA:B:) withSignals:signal01,signal02, nil];
}
/**<6.只有加入到隊列組中的信號都發(fā)送完成才會調(diào)用此方法*/
- (void)sendMessageWithA:(id)A B:(id)B{
    
}

2.信號篩選的一些方法

  • filter（過濾）

    [self.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        return value.length > 3;
    }];

  • ignore（忽略某些值的信號）

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"A"];
        return nil;
    }];
    [[signal ignore:@"A"]subscribeNext:^(NSString *str) {
        NSLog(@"%@",str);
    }];

  • distinctUntilChanged(與上一次的值比較，如果相同則忽略)

    RACSubject *subject = [RACSubject subject];
    [[subject distinctUntilChanged] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    [subject sendNext:@1];
    /**<與上一次發(fā)送的信號值相同時，被過濾*/
    [subject sendNext:@1];

  • switchToLatest(直接取到信號中的信號)

    /**<1.創(chuàng)建RACCommand*/
    RACCommand * command = [[RACCommand alloc] initWithSignalBlock:^RACSignal * _Nonnull(id  _Nullable input) {
        return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            /**<2.發(fā)送信號*/
            [subscriber sendNext:@"我開始跑了"];

            return nil;
        }];
    }];

    /**<3.訂閱RACCommand信號*/
    [command.executionSignals subscribeNext:^(RACSignal  * signal) {
        /**<4.返回的不是一個對象，而是一個信號*/
        [signal.switchToLatest subscribeNext:^(id  _Nullable x) {
            NSLog(@"%@", x);
        }];
    }];

  • take （從開始取幾次信號）

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"我跑了1"];
        [subscriber sendNext:@"我跑了2"];
        [subscriber sendNext:@"我跑了3"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    [[signal take:1] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",  x);
    }];
    
2018-04-09 15:11:24.919993+0800 ReactiveCocoa[69306:5919540] 我跑了1
2018-04-09 15:11:24.920260+0800 ReactiveCocoa[69306:5919540] 我跑了2

  • takeLast(從后開始取到第幾個信號)

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"我跑了1"];
        [subscriber sendNext:@"我跑了2"];
        [subscriber sendNext:@"我跑了3"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    [[signal takeLast:2] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",  x);
    }];
    
2018-04-09 15:12:12.268283+0800 ReactiveCocoa[69357:5921334] 我跑了2
2018-04-09 15:12:12.268645+0800 ReactiveCocoa[69357:5921334] 我跑了3

  • skip（跳過前面N次信號）

 RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"我跑了1"];
        [subscriber sendNext:@"我跑了2"];
        [subscriber sendNext:@"我跑了3"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    [[signal skip:2] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",  x);
    }];
    
 2018-04-09 15:24:20.559315+0800 ReactiveCocoa[69687:5936546] 我跑了3

3.時間控制

  • interval：(定時器)

[[RACSignal interval:3 onScheduler:[RACScheduler scheduler]]subscribeNext:^(NSDate * _Nullable x) {
        NSLog(@"我跑了");
    }];
2018-04-09 15:39:33.315067+0800 ReactiveCocoa[70143:5962467] 我跑了
2018-04-09 15:39:36.315123+0800 ReactiveCocoa[70143:5962467] 我跑了
2018-04-09 15:39:39.314985+0800 ReactiveCocoa[70143:5962467] 我跑了
2018-04-09 15:39:42.315997+0800 ReactiveCocoa[70143:5962467] 我跑了
2018-04-09 15:39:45.315919+0800 ReactiveCocoa[70143:5962467] 我跑了

  • delay (延遲執(zhí)行)

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        NSLog(@"我開始跑的時間是：%@", [NSDate date]);
        [subscriber sendNext:@"我跑了"];
        return nil;
    }];
    
    [[signal delay:3] subscribeNext:^(id  _Nullable x) {
        NSLog(@"我開始跑的時間是%@", [NSDate date]);
    }];

2018-04-09 15:43:50.259748+0800 ReactiveCocoa[70300:5970942] 我開始跑的時間是：2018-04-09 07:43:50 +0000
2018-04-09 15:43:53.264219+0800 ReactiveCocoa[70300:5970942] 我開始跑的時間是: 2018-04-09 07:43:53 +0000

  • timeout (超時)

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        NSLog(@"外面開始派送");
        [subscriber sendNext:@"外賣到了"];
        return nil;
    }];
    
    [[[signal delay:4] timeout:2 onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }error:^(NSError * _Nullable error) {
        NSLog(@"超時了，外賣還沒到");
    }];
    
2018-04-09 15:53:34.852945+0800 ReactiveCocoa[70667:5990089] 外面開始派送
2018-04-09 15:53:36.853049+0800 ReactiveCocoa[70667:5990089] 超時了，外賣還沒到

  • replay （當信號被多次訂閱后，只執(zhí)行了一次block中）

    __block int a = 0;
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        a += 1;
        [subscriber sendNext:@(a)];
        return nil;
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@", x);
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@", x);
    }];

2018-04-09 16:06:24.658880+0800 ReactiveCocoa[71242:6017048] 1
2018-04-09 16:06:24.659232+0800 ReactiveCocoa[71242:6017048] 1

  • retry(當不滿足條件時，需要發(fā)送sendError,之后會重復執(zhí)行block里面的發(fā)送，直到滿足條件為止 )

    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        static int a = 1;
        a++;
        NSLog(@"執(zhí)行");
        if (a > 4) {
            [subscriber sendNext:@"滿足條件"];
        }else{
            [subscriber sendError:nil];
        }
        return  nil;
    }]retry] subscribeNext:^(id  _Nullable x) {

    }];
    
2018-04-09 16:34:42.374092+0800 ReactiveCocoa[72260:6057957] 執(zhí)行
2018-04-09 16:34:42.410639+0800 ReactiveCocoa[72260:6057957] 執(zhí)行
2018-04-09 16:34:42.411376+0800 ReactiveCocoa[72260:6057957] 執(zhí)行
2018-04-09 16:34:42.412637+0800 ReactiveCocoa[72260:6057957] 執(zhí)行
2018-04-09 16:34:42.413060+0800 ReactiveCocoa[72260:6057957] 滿足條件

  • throttle節(jié)流

    [[signalBtn throttle:3] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

4.線程控制

  • deliverOn（將信息控制在指定的線程中執(zhí)行）

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        NSLog(@"%@", [NSThread currentThread]);
        [subscriber sendNext:@"我跑了"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    signal = [signal deliverOn:[RACScheduler mainThreadScheduler]];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@", [NSThread currentThread]);
    }];

2018-04-09 14:54:00.999074+0800 ReactiveCocoa[68757:5891490] <NSThread: 0x60400007d500>{number = 1, name = main}
2018-04-09 14:54:00.999587+0800 ReactiveCocoa[68757:5891647] <NSThread: 0x604000464440>{number = 3, name = (null)}

  • subscribeOn (將信息和副作用控制在指定的線程中執(zhí)行)

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        NSLog(@"%@", [NSThread currentThread]);
        [subscriber sendNext:@"我跑了"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    signal = [signal subscribeOn:[RACScheduler scheduler]];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@", [NSThread currentThread]);
    }];

2018-04-09 14:52:30.782595+0800 ReactiveCocoa[68689:5888475] <NSThread: 0x60000026d540>{number = 3, name = (null)}
2018-04-09 14:52:30.782806+0800 ReactiveCocoa[68689:5888475] <NSThread: 0x60000026d540>{number = 3, name = (null)}
最后編輯于 ：
?著作權歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

相關閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容