学学人家的框架上海恩美路演恩美第二个APP项目

ReactiveCocoa 使用

2017-05-05  本文已影响161人  等这姑娘老在我心里

源代码地址 https://github.com/Liuchunqi3240/demo/tree/master/ReactiveCocoaTour

目录

cocoapods 安装


target 'ReactiveCocoaTour' do

pod 'ReactiveObjC'


end

代码使用

import

#import "ReactiveObjC.h"

textfiled

//textfiled 用法
- (void)textFiledUse{
    
    //直接检测值的变化 坏处是 第一次无变化时也会回调
    @weakify(self);
    [self.textFiled.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
        @strongify(self);
        NSLog(@"textfiled text is %@  x is %@",self.textFiled.text,x);
    }];
    //增加一个过滤条件
    [[self.textFiled.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        return [value hasPrefix:@"x"];
    }] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"x is %@",x);
    }];
    
    //过滤掉特殊字符串不进行调用
    [[self.textFiled.rac_textSignal ignore:@"sunny"] subscribeNext:^(NSString *value) {
        NSLog(@"`sunny` could never appear : %@", value);
    }];
    
    //可以有多个订阅者 依次执行
    RACSignal *signal = self.textFiled.rac_textSignal;
    [signal subscribeNext:^(id x) {
        NSLog(@"1111");
    }];
    [signal subscribeNext:^(id x) {
        NSLog(@"2222");
    }];

}

button target

- (void)buttonUse{
    [[self.button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
        NSLog(@"button click");
    }];
}

skip

- (void)skip{
    //跳过前面两个 skip 填写跳过的个数
    RACSubject *subject = [RACSubject subject];
    [[subject skip:2] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    [subject sendNext:@2];
    [subject sendNext:@3];
    [subject sendNext:@1];
}

distinctUntilChanged

- (void)distinctUntilChanged{
    //和上次一样的信号 不会被订阅
    RACSubject *subject = [RACSubject subject];
    [[subject distinctUntilChanged] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 发送信号
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@2]; // 不会被订阅

}

take

- (void)take{
    //只取前面几个的信号 take:nsinter count
    RACSubject *subject = [RACSubject subject];
    [[subject take:2]subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];
}

takeLast

- (void)takeLast{
    //只取后面几个的信号 takeLast:nsinter count
    RACSubject *subject = [RACSubject subject];
    [[subject takeLast:2] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];
}

takeUntil

- (void)takeUntil{
    //执行到 until的那个信号发出 结束  这里指subject2 发出next 或者 complete
    RACSubject *subject1 = [RACSubject subject];
    RACSubject *subject2 = [RACSubject subject];
    
    [[subject1 takeUntil:subject2] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    [subject1 sendNext:@1];
    [subject1 sendNext:@2];
    
//    [subject2 sendNext:@1];  //和下面 complete 效果相同
    [subject2 sendCompleted];
    
    [subject1 sendNext:@3];

}

switchToLatest

- (void)switchToLatest{
    //只获取最新的信号发出的指令 前面的都释放掉
    RACSubject *signalOfSignals = [RACSubject subject];
    RACSubject *signalA = [RACSubject subject];
    RACSubject *signalB = [RACSubject subject];
    // 获取信号中信号最近发出信号,订阅最近发出的信号。
    // 注意switchToLatest:只能用于信号中的信号
    [signalOfSignals.switchToLatest subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];
    [signalOfSignals sendNext:signalA];
    [signalOfSignals sendNext:signalB];
    [signalA sendNext:@"signalA"];
    [signalB sendNext:@"signalB"];
    
}

doNext doComplete

- (void)doNextAndDoComplete{
    [[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        [subscriber sendNext:@"hi"];
        [subscriber sendCompleted];
        
        return nil;
    }]doNext:^(id  _Nullable x) {
        //在执行    [subscriber sendNext:@"hi"];之前先执行
        NSLog(@"do next");
    }]doCompleted:^{
        //在执行    [subscriber sendCompleted];之前先执行
        NSLog(@"do complete");
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
}

deliverOn


//内容传递切换到制定线程中,副作用在原来线程中,把在创建信号时block中的代码称之为副作用
- (void)deliverOn{
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
       [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
           NSLog(@"%@",[NSThread currentThread]);
           [subscriber sendNext:@1];
           [subscriber sendCompleted];
           return nil;
       }]
        //交付给主线程
        deliverOn:[RACScheduler mainThreadScheduler] ]
        subscribeNext:^(id  _Nullable x) {
            NSLog(@"%@",x);
            NSLog(@"%@",[NSThread currentThread]);
       }];
    });
}

subscribeOn

//内容传递和副作用都会切换到制定线程中
- (void)subscribeOn{
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            NSLog(@"%@",[NSThread currentThread]);
            [subscriber sendNext:@"123"];
            [subscriber sendCompleted];
            return nil;
        }]
        subscribeOn:[RACScheduler mainThreadScheduler]]
        subscribeNext:^(id  _Nullable x) {
            NSLog(@"%@",x);
            NSLog(@"%@",[NSThread currentThread]);
        }];
    });
}


interval

- (void)interval{
    //定时器
    [[RACSignal interval:1.0f onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(NSDate * _Nullable x) {
        NSLog(@"%@",x);
    }];
}

timeOut

- (void)timeOut{
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        //无任何操作 等超时
//        [subscriber sendNext:@"ddsa"];
//        NSError *error = [[NSError alloc]initWithDomain:@"unknwn domain" code:600 userInfo:@{@"error":@"超时"}];
//        [subscriber sendError:error];
//        [subscriber sendCompleted];
        return nil;
    }] timeout:3 onScheduler:[RACScheduler mainThreadScheduler]]subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }error:^(NSError * _Nullable error) {
        NSLog(@"%@",error);
    }];
}

delay

- (void)delay{
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        NSLog(@"send next");
        [subscriber sendNext:@"delay msg"];
        [subscriber sendCompleted];
        return nil;
    }] delay:2]
        subscribeNext:^(id  _Nullable x) {
            NSLog(@"%@",x);
    }];
}

- (void)retry{
    //重试
    //不执行error block  一直到  执行send next 结束
    __block int i = 0;
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        if (i == 5) {
            [subscriber sendNext:@"send next"];
        }else{
            [subscriber sendError:[NSError errorWithDomain:@"unknown domain" code:600 userInfo:@{@"msg":[NSString stringWithFormat:@"%d",i]}]];
        }
        i ++;
        return  nil;
    }]
      retry]
     
     subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }error:^(NSError * _Nullable error) {
        NSLog(@"%@",error);
    }];
}

replay

- (void)replay{
    //多个订阅者 只执行一遍副作用  没有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);
    }];
}


throttle

- (void)throttle{
    //节流 间隔1s以后 订阅者获取最新信号发出的指令 在1S内  sendNext都不会进subscribeBlock中
    RACSubject *subject = [RACSubject subject];
    
    [[subject throttle:1] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];
    [subject sendNext:@4];

}



sequence

- (void)sequence{
//    遍历数组
    NSArray *array = @[@"1",@"2",@"3",@"4",@"5",@"6"];
    
    [array.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@", x);
    }];
//    遍历字典
    NSDictionary *dict = @{@"name":@"张旭",@"age":@24};
    [dict.rac_sequence.signal subscribeNext:^(RACTuple *x) {
        
        RACTupleUnpack(NSString *key,NSString *value) = x;
        
        NSLog(@"%@ %@",key,value);
        
    }];

    
}

notification obsever

- (void)notificationUse{
    [[[NSNotificationCenter defaultCenter]rac_addObserverForName:@"notificationName" object:nil] subscribeNext:^(NSNotification * _Nullable x) {
        NSLog(@"notificaiton is %@",x);
    }];
}

KVO

- (void)KVO{
    UIScrollView *scrolView = [[UIScrollView alloc] initWithFrame:CGRectMake(0, 200, 200, 400)];
    scrolView.contentSize = CGSizeMake(200, 800);
    scrolView.backgroundColor = [UIColor greenColor];
    [self.view addSubview:scrolView];
    [RACObserve(scrolView, contentOffset) subscribeNext:^(id x) {
        NSLog(@"success");
    }];
}

上一篇 下一篇

猜你喜欢

热点阅读