iOS-RAC的一些基础用法

-(void)skip{

//skip传入n跳过前面n个值
RACSubject * subject = [RACSubject subject];
[[subject skip:2] subscribeNext:^(id x) {
   
    NSLog(@"%@",x);
}];

[subject sendNext:@1];
[subject sendNext:@2];
[subject sendNext:@2];

}

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{

RACSubject * subject = [RACSubject subject];
//可以屏蔽一些值,去前面几个值---这里take为2 则只拿到前两个值
[[subject take:2]subscribeNext:^(id x) {
   
    NSLog(@"%@",x);
}];

[subject sendNext:@1];
[subject sendNext:@2];
[subject sendNext:@3];
}

takeLast

 -(void)takeLast {

RACSubject * subject = [RACSubject subject];
//取的是最后几个值
[[subject takeLast:2] subscribeNext:^(id x) {
   
    NSLog(@"%@",x);
}];

[subject sendNext:@1];
[subject sendNext:@2];
[subject sendNext:@3];
[subject sendCompleted];//不写会取不到最后要的值
}

takeUntil

-(void)takeUntil{


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];//调用后不会收到下边发送的内容
 //    [subject2 sendCompleted];//
    [subject2 sendNext:@4];
 }

ignore

-(void)ignore{

//    ignore 忽略一些值
//    ignoreValue 忽略所有的值

RACSubject * subject = [RACSubject subject];

RACSignal * ignoreSignal = [subject ignore:@2];//忽略2

[ignoreSignal subscribeNext:^(id x) {
    NSLog(@"%@",x);
}];

[subject sendNext:@2];

}

fliter

-(void)fliter{


[[textField.rac_textSignal filter:^BOOL(id value) {
    
    return [value length] > 5;//返回值就是过滤条件 满足才能获取到
}] subscribeNext:^(id x) {
   
    NSLog(@"%@",x);
}];

}

zipWith

 -(void)zipWith{
 //zipWith:把两个信号压缩成一个信号，只有当两个信号同时发出信号内容时，并且把两个信号的内容合并成一个元祖，才会触发压缩流的next事件。
 //使用场:当一个界面多个请求的时候，要等所有请求完成才更新UI
RACSubject * signalA = [RACSubject subject];

RACSubject * signalB = [RACSubject subject];

RACSignal * zipSignal = [signalA zipWith:signalB];//跟压缩的顺序有关 先A后B
//等所有信号都发送内容的时候才会调用
[zipSignal subscribeNext:^(id x) {
   
    NSLog(@"%@",x);
}];

[signalA sendNext:@1];
[signalB sendNext:@2];
}

merge
多个信号合并成一个信号，任何一个信号有新值就会调用 ,任何一个信号请求完成都会被订阅到

 -(void)merge{

RACSubject * signalA = [RACSubject subject];

RACSubject * signalB = [RACSubject subject];

//组合信号
RACSignal * mergeSignal = [signalA merge:signalB];

//
[mergeSignal subscribeNext:^(id x) {
    NSLog(@"%@",x);
}];
    // 发送信号---交换位置则数据结果顺序也会交换
[signalB sendNext:@2];
[signalA sendNext:@1];
}

then 使用需求：有两部分数据：想让上部分先进行网络请求但是过滤掉数据，然后进行下部分的，拿到下部分数据

-(void)then{

RACSignal * signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
   
    NSLog(@"----发送上部分请求---afn");
    
    [subscriber sendNext:@"上部分数据"];
    [subscriber sendCompleted];
    return nil;
}];

RACSignal * signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
   
    NSLog(@"--发送下部分请求--afn");
    
    [subscriber sendNext:@"下部分数据"];
    [subscriber sendCompleted];
    return nil;
}];

// 创建组合信号
// then;忽略掉第一个信号的所有值

RACSignal * thenSignal = [signalA then:^RACSignal *{
    return signalB;// 返回的信号就是要组合的信号
}];

[thenSignal subscribeNext:^(id x) {
    NSLog(@"%@",x);
}];
 }

concat----- 使用需求：有两部分数据：想让上部分先执行，完了之后再让下部分执行（都可获取值） ，类似于同步

-(void)concat{

RACSignal * signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
    
    NSLog(@"----发送上部分请求---afn");
    
    [subscriber sendNext:@"上部分数据"];
    [subscriber sendCompleted];
    return nil;
}];

RACSignal * signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
    
    NSLog(@"--发送下部分请求--afn");
    
    [subscriber sendNext:@"下部分数据"];
  //        [subscriber sendCompleted];
    return nil;
}];

//**-注意-**：concat，第一个信号必须要调用sendCompleted
RACSignal * concatSignal = [signalA concat:signalB];

[concatSignal subscribeNext:^(id x) {
   
    NSLog(@"%@",x);
}];

}