ReactiveObjC基础用法

iOS开发三种编程方式(响应式编程、函数编程、链式编程),函数编程最常用，链式编程代码可读性好，然而响应式编程方便，都知道开发刷新UI，一般都是重新调用系统api实现（例如[self.tableview reloadata]刷新列表），但是有没有像前端web vue那种改变数据就可以刷新页面的呢？答案是肯定的，iOS开发也是具有这种响应式编程的，其中最具有代表性的就是ReactiveObjC、ReactiveCocoa分别对应OC、Swift。这2个都是比较方便的响应式框架，开发中也非常的方便，我们可以把它叫做函数式响应开发。

ReactiveObjC到底能做什么呢？

ReactiveObjC可以代替开发中很多常用操作，比如定时器、kvo、代理、通知、点击事件、监听等操作。下面我们就从入门开始
ReactiveObjC里面最重要的就是信号(RACSignal)

 //创建信号 开发中一般结合网络请求使用，请求成功后回调sendNext�：
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        //发送信号
        [subscriber sendNext:@[@"xxxxx"]];
        [subscriber sendCompleted];
        return  nil;
    } ];
    //订阅信号
    RACDisposable *dis = [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    //xx注销dealloc
    [dis dispose];

ReactiveObjc在UI(监听文本变化，监听按钮点击事件等)使用

   //rac监听文本
    UITextField *textFiled = nil;
    [[textFiled rac_textSignal]subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];
    //filter 监听文本 p满足文本长度执行，列如控制输入密码长度
    [[[textFiled rac_textSignal]filter:^BOOL(NSString * _Nullable value) {
        return value.length >10;
    }]subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];
    //过滤条件
    [[[textFiled rac_textSignal]ignore:@"非法字符"]subscribeNext:^(NSString * _Nullable x) {
        //如果是非法字符，不会来到这里
        NSLog(@"打印结果%@",x);
    }];
   // 使用RAC宏，只要文本框文字改变，就会修改label的文字
    RAC(self.labelView,text) = _textField.rac_textSignal;
 //监听按钮点击事件
 UIButton *btn = nil;
    [[btn rac_signalForControlEvents:UIControlEventTouchUpInside]subscribeNext:^(__kindof   UIControl * _Nullable x) {
       //不需要使用@selector写一个按钮点击事件了,按钮回调在这里
        NSLog(@"%@",x);
    }];

ReactiveObjc中使用通知、定时器

//订阅信号
//@property(nonatomic,strong)RACDisposable *disposable;
self.disposable =  [[[NSNotificationCenter defaultCenter]rac_addObserverForName:@"notiName" object:nil]subscribeNext:^(NSNotification * _Nullable x) {
        //不需要写通知复杂的方法，通知回调写在这里面
        //x就是通知返回的对象userInfo
        NSLog(@"%@",x);
     }];
     [[NSNotificationCenter defaultCenter]postNotificationName:@"notiName" object:nil userInfo:@{@"name":@"gxxx"}];
    //dealloc 注销通知
    [self.disposable dispose];

//定时器
    RACSignal *signal = [RACSignal interval:1.0 onScheduler:[RACScheduler mainThreadScheduler]];
    //设置定时器总时间
    signal = [signal take:10];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"执行次数%@",x);
    }completed:^{
        NSLog(@"完成");
    }];
  

ReactiveObjc遍历数组和字典

  NSArray *array = @[@"1",@"2",@"3"];
  [array.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
      NSLog(@"%@",x);
   }];

  NSDictionary *dict = @{@"name":@"g",@"age":@"12"};
    [dict.rac_sequence.signal subscribeNext:^(RACTuple *  _Nullable x) {
        //RACTupleUnpack我一个强大的宏，遍历字典
        RACTupleUnpack(NSString *key,NSString *value) = x;
        NSLog(@"%@-%@",key,value);
    }];

ReactiveObjc代替代理、kvo使用

声明协议类
@property(nonatomic,strong)RACSubject *delegate;
@implementation testView

-(instancetype)initWithFrame:(CGRect)frame
{
    if (self = [super initWithFrame:frame]) {
        self.backgroundColor = [UIColor redColor];
    }
    return self;
}

-(void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event
{
    if (self.delegate) {
        [self.delegate sendNext:@[@"2"]];
    }
}

@end
//代理类实现
@interface ViewController ()
@property(nonatomic,strong)testView *testV;
@end
@implementation ViewController
- (void)viewDidLoad {
    [super viewDidLoad];
    self.testV = [[testView alloc]initWithFrame:CGRectMake(0, 0, 100, 100)];
    [self.view addSubview:self.testV];
    self.testV.delegate = [RACSubject subject];
    [self.testV.delegate subscribeNext:^(id  _Nullable x) {
        //这里就是类似delegate实现方法
        NSLog(@"%@",x);
    }];
   
}
@end

//代替kvo
@interface ViewController ()
@property(nonatomic,copy)NSString *name;
@end
@implementation ViewController
- (void)viewDidLoad {
    [super viewDidLoad];
    self.name = @"1";
    //rac_valuesForKeyPath 通过keyPath监听
    [[self rac_valuesForKeyPath:NSStringFromSelector(@selector(name)) observer:self]subscribeNext:^(id  _Nullable x) {
        NSLog(@"kvc %@",x);
    }];
    //通过属性监听
    [[RACObserve(self, name) filter:^BOOL(id  _Nullable value) {
        NSLog(@"fileter%@",value);
        return value;
    }]subscribeNext:^(id  _Nullable x) {
        NSLog(@"属性监听%@",x);
    }];
}

-(void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event
{
    self.name = @"2";
}
@end

//除此之外还可以合并信号，处理多个网络请求，以满足具体开发要求要求，也就可以替代栅栏函数了