ReactiveCocoa学习

@weakify(self);
[RACObserve(self,value) subscribeNext:^(NSString* x) {
    @strongify(self);
    NSLog(@"你动了");
}];

1

2

3

4

5

@ weakify ( self ) ;

[ RACObserve ( self , value ) subscribeNext @H_502_87@: @H_502_87@^ ( NSString @H_502_87@* x ) {

@ strongify ( self ) ;

NSLog ( @"你动了" ) ;

} ] ;

RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"唱歌"];
        [subscriber sendCompleted];
        return nil;
    }];
    RAC(self,value) = [signalA map:^id(NSString* value) {
        if ([value isEqualToString:@"唱歌"]) {
            return @"跳舞";
        }
        return @"";
    }];

1

2

3

4

5

6

7

8

9

10

11

RACSignal *signalA @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"唱歌" ] ;

[ subscriber sendCompleted ] ;

return nil ;

} ] ;

RAC ( self , value ) @H_502_87@= [ signalA map @H_502_87@: @H_502_87@^ id ( NSString @H_502_87@* value ) {

if ( [ value isEqualToString @H_502_87@: @"唱歌" ] ) {

return @"跳舞" ;

}

@H_773_404@ return @"" ;

} ] ;

RACChannelTerminal *channelA = RACChannelTo(self,valueA);
    RACChannelTerminal *channelB = RACChannelTo(self,valueB);
    [[channelA map:^id(NSString *value) {
        if ([value isEqualToString:@"西"]) {
            return @"东";
        }
        return value;
    }] subscribe:channelB];
    [[channelB map:^id(NSString *value) {
        if ([value isEqualToString:@"左"]) {
            return @"右";
        }
        return value;
    }] subscribe:channelA];
    [[RACObserve(self,valueA) filter:^BOOL(id value) {
        return value ? YES : NO;
    }] subscribeNext:^(NSString* x) {
        NSLog(@"你向%@",x);
    }];
    [[RACObserve(self,valueB) filter:^BOOL(id value) {
        return value ? YES : NO;
    }] subscribeNext:^(NSString* x) {
        NSLog(@"他向%@",x);
    }];
    self.valueA = @"西";
    self.valueB = @"左";

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

RACChannelTerminal *channelA @H_502_87@= RACChannelTo ( self , valueA ) ;

RACChannelTerminal *channelB @H_502_87@= RACChannelTo ( self , valueB ) ;

[ [ channelA map @H_502_87@: @H_502_87@^ id ( NSString *value ) {

if ( [ value isEqualToString @H_502_87@: @"西" ] ) {

return @"东" ;

}

return value ;

} ] subscribe :channelB ] ;

[ [ channelB map @H_502_87@: @H_502_87@^ id ( NSString *value ) {

if ( [ value isEqualToString @H_502_87@: @"左" ] ) {

return @"右" ;

}

return value ;

} ] subscribe :channelA ] ;

[ [ RACObserve ( self , valueA ) filter @H_502_87@: @H_502_87@^ BOOL ( id value ) {

return value ? YES : NO ;

} ] subscribeNext @H_502_87@: @H_502_87@^ ( NSString @H_502_87@* x ) {

NSLog ( @"你向%@" , x ) ;

} ] ;

[ [ RACObserve ( self , valueB ) filter @H_502_87@: @H_502_87@^ BOOL ( id value ) {

return value ? YES : NO ;

} ] subscribeNext @H_502_87@: @H_502_87@^ ( NSString @H_502_87@* x ) {

NSLog ( @"他向%@" , x ) ;

} ] ;

self . valueA @H_502_87@= @"西" ;

self . valueB @H_502_87@= @"左" ;

2015-08-15 20:14:46.544 Test[2440:99901] 你向西  
2015-08-15 20:14:46.544 Test[2440:99901] 他向东  
2015-08-15 20:14:46.545 Test[2440:99901] 他向左  
2015-08-15 20:14:46.545 Test[2440:99901] 你向右

1

2

3

4

2015 @H_502_87@- 08 @H_502_87@- 15 20 @H_502_87@: 14 @H_502_87@: 46.544 Test [ 2440 @H_502_87@: 99901 ] 你向西

2015 @H_502_87@- 08 @H_502_87@- 15 20 @H_502_87@: 14 @H_502_87@: 46.544 Test [ 2440 @H_502_87@: 99901 ] 他向东

2015 @H_502_87@- 08 @H_502_87@- 15 20 @H_502_87@: 14 @H_502_87@: 46.545 Test [ 2440 @H_502_87@: 99901 ] 他向左

2015 @H_502_87@- 08 @H_502_87@- 15 20 @H_502_87@: 14 @H_502_87@: 46.545 Test [ 2440 @H_502_87@: 99901 ] 你向右

@protocol Programmer <NSObject>
- (void)makeAnApp;
@end

1

2

3

@protocol Programmer <NSObject>

@H_502_87@- ( void ) makeAnApp ;

@end

RACSignal *ProgrammerSignal =  
[self rac_signalForSelector:@selector(makeAnApp)
               fromProtocol:@protocol(Programmer)];
[ProgrammerSignal subscribeNext:^(RACTuple* x) {
    NSLog(@"花了一个月，app写好了");
}];
[self makeAnApp];

1

2

3

4

5

6

7

@H_301_1398@ RACSignal *ProgrammerSignal @H_502_87@=

[ self rac_signalForSelector @H_502_87@: @selector ( makeAnApp )

fromProtocol @H_502_87@: @protocol ( Programmer ) ] ;

[ ProgrammerSignal subscribeNext @H_502_87@: @H_502_87@^ ( RACTuple @H_502_87@* x ) {

NSLog ( @"花了一个月，app写好了" ) ;

} ] ;

[ self makeAnApp ] ;

2015-08-15 20:46:45.720 Test[2817:114564] 花了一个月，app写好了

1	2015 @H_502_87@- 08 @H_502_87@- 15 20 @H_502_87@: 46 @H_502_87@: 45.720 Test [ 2817 @H_502_87@: 114564 ] 花了一个月， app写好了

[[[NSNotificationCenter defaultCenter] rac_addObserverForName:@"<a href="/tag/daima/" target="_blank" class="keywords">代码</a>之道频道" object:nil] subscribeNext:^(NSNotification* x) {
        NSLog(@"技巧：%@",x.userInfo[@"技巧"]);
    }];
    [[NSNotificationCenter defaultCenter] postNotificationName:@"<a href="/tag/daima/" target="_blank" class="keywords">代码</a>之道频道" object:nil userInfo:@{@"技巧":@"用心写"}];

1

2

3

4

[ [ [ NSNotificationCenter defaultCenter ] rac_addObserverForName @H_502_87@: @"代码之道频道" object :nil ] subscribeNext @H_502_87@: @H_502_87@^ ( NSNotification @H_502_87@* x ) {

NSLog ( @"技巧：%@" , x . userInfo [ @"技巧" ] ) ;

} ] ;

[ [ NSNotificationCenter defaultCenter ] postNotificationName @H_502_87@: @"代码之道频道" object :nil userInfo @H_502_87@: @ { @"技巧" @H_502_87@: @"用心写" } ] ;

2015-08-15 20:41:15.786 Test[2734:111505] 技巧：用心写

1	2015 @H_502_87@- 08 @H_502_87@- 15 20 @H_502_87@: 41 @H_502_87@: 15.786 Test [ 2734 @H_502_87@: 111505 ] 技巧：用心写

    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"我恋爱啦"];
        [subscriber sendCompleted];
        return nil;
    }];
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"我结婚啦"];
        [subscriber sendCompleted];
        return nil;
    }];
    [[signalA concat:signalB] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

RACSignal *signalA @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"我恋爱啦" ] ;

[ subscriber sendCompleted ] ;

return nil ;

} ] ;

RACSignal *signalB @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"我结婚啦" ] ;

[ subscriber sendCompleted ] ;

return nil ;

} ] ;

[ [ signalA concat :signalB ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"%@" , x ) ;

} ] ;

2015-08-15 12:19:46.707 Test[1845:64122] 我恋爱啦  
2015-08-15 12:19:46.707 Test[1845:64122] 我结婚啦

1 2	2015 @H_502_87@- 08 @H_502_87@- 15 12 @H_502_87@: 19 @H_502_87@: 46.707 Test [ 1845 @H_502_87@: 64122 ] 我恋爱啦 2015 @H_502_87@- 08 @H_502_87@- 15 12 @H_502_87@: 19 @H_502_87@: 46.707 Test [ 1845 @H_502_87@: 64122 ] 我结婚啦

RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"纸厂污水"];
        return nil;
    }];
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"电镀厂污水"];
        return nil;
    }];
    [[RACSignal merge:@[signalA,signalB]] subscribeNext:^(id x) {
        NSLog(@"处理%@",x);
    }];

1

2

3

4

5

6

7

8

9

10

11

RACSignal *signalA @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"纸厂污水" ] ;

return nil ;

} ] ;

RACSignal *signalB @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"电镀厂污水" ] ;

return nil ;

} ] ;

[ [ RACSignal merge @H_502_87@: @ [ signalA , signalB ] ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"处理%@" , x ) ;

} ] ;

2015-08-15 12:10:05.371 Test[1770:60147] 处理纸厂污水  
2015-08-15 12:10:05.372 Test[1770:60147] 处理电镀厂污水

1 2	2015 @H_502_87@- 08 @H_502_87@- 15 12 @H_502_87@: 10 @H_502_87@: 05.371 Test [ 1770 @H_502_87@: 60147 ] 处理纸厂污水 2015 @H_502_87@- 08 @H_502_87@- 15 12 @H_502_87@: 10 @H_502_87@: 05.372 Test [ 1770 @H_502_87@: 60147 ] 处理电镀厂污水

RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"红"];
        [subscriber sendNext:@"白"];
        return nil;
    }];
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"白"];
        return nil;
    }];
    [[RACSignal combineLatest:@[signalA,signalB]] subscribeNext:^(RACTuple* x) {
        RACTupleUnpack(NSString *stringA,NSString *stringB) = x;
        NSLog(@"我们是%@%@的",stringA,stringB);
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

RACSignal *signalA @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"红" ] ;

[ subscriber sendNext @H_502_87@: @"白" ] ;

return nil ;

} ] ;

RACSignal *signalB @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"白" ] ;

return nil ;

} ] ;

[ [ RACSignal combineLatest @H_502_87@: @ [ signalA , signalB ] ] subscribeNext @H_502_87@: @H_502_87@^ ( RACTuple @H_502_87@* x ) {

@H_655_3016@ RACTupleUnpack ( NSString *stringA , NSString *stringB ) @H_502_87@= x ;

NSLog ( @"我们是%@%@的" , stringA , stringB ) ;

} ] ;

2015-08-15 12:14:19.837 Test[1808:62042] 我们就是红黄的  
2015-08-15 12:14:19.837 Test[1808:62042] 我们是白黄的

1 2	2015 @H_502_87@- 08 @H_502_87@- 15 12 @H_502_87@: 14 @H_502_87@: 19.837 Test [ 1808 @H_502_87@: 62042 ] 我们就是红黄的 2015 @H_502_87@- 08 @H_502_87@- 15 12 @H_502_87@: 14 @H_502_87@: 19.837 Test [ 1808 @H_502_87@: 62042 ] 我们是白黄的

RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"红"];
        [subscriber sendNext:@"白"];
        return nil;
    }];
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"白"];
        return nil;
    }];
    [[signalA zipWith:signalB] subscribeNext:^(RACTuple* x) {
        RACTupleUnpack(NSString *stringA,stringB);
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

RACSignal *signalA @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"红" ] ;

[ subscriber sendNext @H_502_87@: @"白" ] ;

return nil ;

} ] ;

RACSignal *signalB @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"白" ] ;

return nil ;

} ] ;

[ [ signalA zipWith :signalB ] subscribeNext @H_502_87@: @H_502_87@^ ( RACTuple @H_502_87@* x ) {

RACTupleUnpack ( NSString *stringA , NSString *stringB ) @H_502_87@= x ;

NSLog ( @"我们是%@%@的" , stringB ) ;

} ] ;

2015-08-15 20:34:24.274 Test[2660:108483] 我们是红白的

1	2015 @H_502_87@- 08 @H_502_87@- 15 20 @H_502_87@: 34 @H_502_87@: 24.274 Test [ 2660 @H_502_87@: 108483 ] 我们是红白的

 RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"石"];
        return nil;
    }] map:^id(NSString* value) {
        if ([value isEqualToString:@"石"]) {
            return @"金";
        }
        return value;
    }];
    [signal subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

1

2

3

4

5

6

7

8

9

10

11

12

RACSignal *signal @H_502_87@= [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"石" ] ;

return nil ;

} ] map @H_502_87@: @H_502_87@^ id ( NSString @H_502_87@* value ) {

if ( [ value isEqualToString @H_502_87@: @"石" ] ) {

return @"金" ;

}

return value ;

} ] ;

[ signal subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"%@" , x ) ;

} ] ;

2015-08-16 20:00:12.853 Test[740:15871] 金

1	2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 00 @H_502_87@: 12.853 Test [ 740 @H_502_87@: 15871 ] 金

RACSignal *sugarSignal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"糖"];
        return nil;
    }];
    RACSignal *waterSignal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"水"];
        return nil;
    }];
    [[RACSignal combineLatest:@[sugarSignal,waterSignal] reduce:^id (NSString* sugar,NSString*water){
        return [sugar stringByAppendingString:water];
    }] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

RACSignal *sugarSignal @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"糖" ] ;

return nil ;

} ] ;

RACSignal *waterSignal @H_502_87@= [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"水" ] ;

return nil ;

} ] ;

[ [ RACSignal combineLatest @H_502_87@: @ [ sugarSignal , waterSignal ] reduce @H_502_87@: @H_502_87@^ id ( NSString @H_502_87@* sugar , NSString *water ) {

return [ sugar stringByAppendingString :water ] ;

} ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"%@" , x ) ;

} ] ;

2015-08-16 20:07:00.356 Test[807:19177] 糖水

1	2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 07 @H_502_87@: 00.356 Test [ 807 @H_502_87@: 19177 ] 糖水

 [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@(15)];
        [subscriber sendNext:@(17)];
        [subscriber sendNext:@(21)];
        [subscriber sendNext:@(14)];
        [subscriber sendNext:@(30)];
        return nil;
    }] filter:^BOOL(NSNumber* value) {
        return value.integerValue >= 18;
    }] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

1

2

3

4

5

6

7

8

9

10

11

12

[ [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @ ( 15 ) ] ;

[ subscriber sendNext @H_502_87@: @ ( 17 ) ] ;

[ subscriber sendNext @H_502_87@: @ ( 21 ) ] ;

[ subscriber sendNext @H_502_87@: @ ( 14 ) ] ;

[ subscriber sendNext @H_502_87@: @ ( 30 ) ] ;

return nil ;

} ] filter @H_502_87@: @H_502_87@^ BOOL ( NSNumber @H_502_87@* value ) {

return value . integerValue @H_502_87@>= 18 ;

} ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"%@" , x ) ;

} ] ;

2015-08-16 20:11:20.071 Test[860:21214] 21  
2015-08-16 20:11:20.071 Test[860:21214] 30

1 2	2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 11 @H_502_87@: 20.071 Test [ 860 @H_502_87@: 21214 ] 21 2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 11 @H_502_87@: 20.071 Test [ 860 @H_502_87@: 21214 ] 30

 [[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSLog(@"打蛋液");
        [subscriber sendNext:@"蛋液"];
        [subscriber sendCompleted];
        return nil;
    }] flattenMap:^RACStream *(NSString* value) {
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            NSLog(@"把%@倒进锅里面煎",value);
            [subscriber sendNext:@"煎蛋"];
            [subscriber sendCompleted];
            return nil;
        }];
    }] flattenMap:^RACStream *(NSString* value) {
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            NSLog(@"把%@装到盘里",value);
            [subscriber sendNext:@"上菜"];
            [subscriber sendCompleted];
            return nil;
        }];
    }] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

[ [ [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"打蛋液" ) ;

[ subscriber sendNext @H_502_87@: @"蛋液" ] ;

[ subscriber sendCompleted ] ;

return nil ;

} ] flattenMap @H_502_87@: @H_502_87@^ RACStream @H_502_87@* ( NSString @H_502_87@* value ) {

return [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"把%@倒进锅里面煎" , value ) ;

[ subscriber sendNext @H_502_87@: @"煎蛋" ] ;

[ subscriber sendCompleted ] ;

return nil ;

} ] ;

} ] flattenMap @H_502_87@: @H_502_87@^ RACStream @H_502_87@* ( NSString @H_502_87@* value ) {

return [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"把%@装到盘里" , value ) ;

[ subscriber sendNext @H_502_87@: @"上菜" ] ;

[ subscriber sendCompleted ] ;

return nil ;

} ] ;

} ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"%@" , x ) ;

} ] ;

2015-08-16 20:39:34.786 Test[1226:34386] 打蛋液  
2015-08-16 20:39:34.787 Test[1226:34386] 把蛋液倒进锅里面煎  
2015-08-16 20:39:34.787 Test[1226:34386] 把煎蛋装到盘里  
2015-08-16 20:39:34.787 Test[1226:34386] 上菜

1

2

3

4

2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 39 @H_502_87@: 34.786 Test [ 1226 @H_502_87@: 34386 ] 打蛋液

2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 39 @H_502_87@: 34.787 Test [ 1226 @H_502_87@: 34386 ] 把蛋液倒进锅里面煎

2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 39 @H_502_87@: 34.787 Test [ 1226 @H_502_87@: 34386 ] 把煎蛋装到盘里

2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 39 @H_502_87@: 34.787 Test [ 1226 @H_502_87@: 34386 ] 上菜

[[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSLog(@"打开冰箱门");
        [subscriber sendCompleted];
        return nil;
    }] then:^RACSignal *{
       return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
           NSLog(@"把大象塞进冰箱");
           [subscriber sendCompleted];
           return nil;
       }];
    }] then:^RACSignal *{
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            NSLog(@"关上冰箱门");
            [subscriber sendCompleted];
            return nil;
        }];
    }] subscribeCompleted:^{
        NSLog(@"把大象塞进冰箱了");
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

[ [ [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"打开冰箱门" ) ;

[ subscriber sendCompleted ] ;

return nil ;

} ] then @H_502_87@: @H_502_87@^ RACSignal @H_502_87@* {

return [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"把大象塞进冰箱" ) ;

[ subscriber sendCompleted ] ;

return nil ;

} ] ;

} ] then @H_502_87@: @H_502_87@^ RACSignal @H_502_87@* {

return [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"关上冰箱门" ) ;

[ subscriber sendCompleted ] ;

return nil ;

} ] ;

} ] subscribeCompleted @H_502_87@: @H_502_87@^ {

NSLog ( @"把大象塞进冰箱了" ) ;

} ] ;

2015-08-16 20:45:27.724 Test[1334:37870] 打开冰箱门  
2015-08-16 20:45:27.725 Test[1334:37870] 把大象塞进冰箱  
2015-08-16 20:45:27.725 Test[1334:37870] 关上冰箱门  
2015-08-16 20:45:27.726 Test[1334:37870] 把大象塞进冰箱了

1

2

3

4

2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 45 @H_502_87@: 27.724 Test [ 1334 @H_502_87@: 37870 ] 打开冰箱门

2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 45 @H_502_87@: 27.725 Test [ 1334 @H_502_87@: 37870 ] 把大象塞进冰箱

@H_502_6192@ 2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 45 @H_502_87@: 27.725 Test [ 1334 @H_502_87@: 37870 ] 关上冰箱门

2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 45 @H_502_87@: 27.726 Test [ 1334 @H_502_87@: 37870 ] 把大象塞进冰箱了

RACCommand *aCommand = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
       return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
           NSLog(@"我投降了");
           [subscriber sendCompleted];
           return nil;
       }];
    }];
    [aCommand execute:nil];

1

2

3

4

5

6

7

8

RACCommand *aCommand @H_502_87@= [ [ RACCommand alloc ] initWithSignalBlock @H_502_87@: @H_502_87@^ RACSignal @H_502_87@* ( id input ) {

return [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"我投降了" ) ;

[ subscriber sendCompleted ] ;

return nil ;

} ] ;

[ aCommand execute :nil ] ;

2015-08-16 20:54:32.492 Test[1450:41849] 我投降了

1	2015 @H_502_87@- 08 @H_502_87@- 16 20 @H_502_87@: 54 @H_502_87@: 32.492 Test [ 1450 @H_502_87@: 41849 ] 我投降了

[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSLog(@"等等我，我还有10秒钟就到了");
        [subscriber sendNext:nil];
        [subscriber sendCompleted];
        return nil;
    }] delay:10] subscribeNext:^(id x) {
        NSLog(@"我到了");
    }];

1

2

3

4

5

6

7

8

[ [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"等等我，我还有10秒钟就到了" ) ;

[ subscriber sendNext :nil ] ;

[ subscriber sendCompleted ] ;

return nil ;

} ] delay @H_502_87@: 10 ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"我到了" ) ;

} ] ;

2015-08-16 21:00:57.622 Test[1619:45924] 等等我，我还有10秒钟就到了  
2015-08-16 21:01:07.624 Test[1619:45924] 我到了

1 2	2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 00 @H_502_87@: 57.622 Test [ 1619 @H_502_87@: 45924 ] 等等我，我还有 10秒钟就到了 2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 01 @H_502_87@: 07.624 Test [ 1619 @H_502_87@: 45924 ] 我到了

RACSignal *replaySignal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSLog(@"大导演拍了一部电影《我的男票是程序员》");
        [subscriber sendNext:@"《我的男票是程序员》"];
        return nil;
    }] replay];
    [replaySignal subscribeNext:^(id x) {
        NSLog(@"小明看了%@",x);
    }];
    [replaySignal subscribeNext:^(id x) {
        NSLog(@"小红也看了%@",x);
    }];

1

2

3

4

5

6

7

8

9

10

11

RACSignal *replaySignal @H_502_87@= [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"大导演拍了一部电影《我的男票是程序员》" ) ;

[ subscriber sendNext @H_502_87@: @"《我的男票是程序员》" ] ;

return nil ;

} ] replay ] ;

[ replaySignal subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"小明看了%@" , x ) ;

} ] ;

[ replaySignal subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"小红也看了%@" , x ) ;

} ] ;

2015-08-16 21:18:38.002 Test[1854:54712] 大导演拍了一部电影《我的男票是程序员》  
2015-08-16 21:18:38.004 Test[1854:54712] 小明看了《我的男票是程序员》  
2015-08-16 21:18:38.004 Test[1854:54712] 小红也看了《我的男票是程序员》

1

2

3

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 18 @H_502_87@: 38.002 Test [ 1854 @H_502_87@: 54712 ] 大导演拍了一部电影《我的男票是程序员》

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 18 @H_502_87@: 38.004 Test [ 1854 @H_502_87@: 54712 ] 小明看了《我的男票是程序员》

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 18 @H_502_87@: 38.004 Test [ 1854 @H_502_87@: 54712 ] 小红也看了《我的男票是程序员》

[[RACSignal interval:60*60*8 onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(id x) {
        NSLog(@"吃药");
    }];

1

2

3

[ [ RACSignal interval @H_502_87@: 60 @H_502_87@* 60 @H_502_87@* 8 onScheduler @H_502_87@: [ RACScheduler mainThreadScheduler ] ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"吃药" ) ;

} ] ;

 [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            NSLog(@"我快到了");
            [subscriber sendNext:nil];
            [subscriber sendCompleted];
            return nil;
        }] delay:60*70] subscribeNext:^(id x) {
            [subscriber sendNext:nil];
            [subscriber sendCompleted];
        }];
        return nil;
    }] timeout:60*60 onScheduler:[RACScheduler mainThreadScheduler]] subscribeError:^(NSError *error) {
        NSLog(@"等了你一个小时了，你还没来，我走了");
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

14

[ [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

NSLog ( @"我快到了" ) ;

[ subscriber sendNext :nil ] ;

[ subscriber sendCompleted ] ;

return nil ;

} ] delay @H_502_87@: 60 @H_502_87@* 70 ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

[ subscriber sendNext :nil ] ;

[ subscriber sendCompleted ] ;

} ] ;

return nil ;

} ] timeout @H_502_87@: 60 @H_502_87@* 60 onScheduler @H_502_87@: [ RACScheduler mainThreadScheduler ] ] subscribeError @H_502_87@: @H_502_87@^ ( NSError *error ) {

NSLog ( @"等了你一个小时了，你还没来，我走了" ) ;

} ] ;

2015-08-16 21:40:09.068 Test[2041:64720] 我快到了  
2015-08-16 22:40:10.048 Test[2041:64720] 等了你一个小时了，你还没来，我走了

1 2	2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 40 @H_502_87@: 09.068 Test [ 2041 @H_502_87@: 64720 ] 我快到了 2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 40 @H_502_87@: 10.048 Test [ 2041 @H_502_87@: 64720 ] 等了你一个小时了，你还没来，我走了

__block int <a href="/tag/Failed/" target="_blank" class="keywords">Failed</a>Count = 0;
    [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        if (<a href="/tag/Failed/" target="_blank" class="keywords">Failed</a>Count < 100) {
            <a href="/tag/Failed/" target="_blank" class="keywords">Failed</a>Count++;
            NSLog(@"我失败了");
            [subscriber sendError:nil];
        }else{
            NSLog(@"经历了数百次失败后");
            [subscriber sendNext:nil];
        }
        return nil;
    }] retry] subscribeNext:^(id x) {
        NSLog(@"终于成功了");
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

14

__block int FailedCount @H_502_87@= 0 ;

[ [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

if ( FailedCount @H_502_87@< 100 ) {

FailedCount @H_502_87@++ ;

NSLog ( @"我失败了" ) ;

[ subscriber sendError :nil ] ;

} else {

NSLog ( @"经历了数百次失败后" ) ;

[ subscriber sendNext :nil ] ;

}

return nil ;

} ] retry ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"终于成功了" ) ;

} ] ;

2015-08-16 21:59:07.159 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.159 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.159 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.159 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.160 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.160 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.161 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.162 Test[2411:77080] 我失败了  
...
2015-08-16 21:59:07.162 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.163 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.163 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.163 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.164 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.164 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.164 Test[2411:77080] 我失败了  
2015-08-16 21:59:07.165 Test[2411:77080] 经历了数百次失败后  
2015-08-16 21:59:07.165 Test[2411:77080] 终于成功了

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 59 @H_502_87@: 07.159 Test [ 2411 @H_502_87@: 77080 ] 我失败了

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 59 @H_502_87@: 07.160 Test [ 2411 @H_502_87@: 77080 ] 我失败了

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 59 @H_502_87@: 07.161 Test [ 2411 @H_502_87@: 77080 ] 我失败了

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 59 @H_502_87@: 07.162 Test [ 2411 @H_502_87@: 77080 ] 我失败了

. . .

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 59 @H_502_87@: 07.162 Test [ 2411 @H_502_87@: 77080 ] 我失败了

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 59 @H_502_87@: 07.163 Test [ 2411 @H_502_87@: 77080 ] 我失败了

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 59 @H_502_87@: 07.164 Test [ 2411 @H_502_87@: 77080 ] 我失败了

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 59 @H_502_87@: 07.165 Test [ 2411 @H_502_87@: 77080 ] 经历了数百次失败后

2015 @H_502_87@- 08 @H_502_87@- 16 21 @H_502_87@: 59 @H_502_87@: 07.165 Test [ 2411 @H_502_87@: 77080 ] 终于成功了

[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"旅客A"];
        dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(1 * NSEC_PER_SEC)),dispatch_get_main_queue(),^{
            [subscriber sendNext:@"旅客B"];
        });
        dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(2 * NSEC_PER_SEC)),^{
            [subscriber sendNext:@"旅客C"];
            [subscriber sendNext:@"旅客D"];
            [subscriber sendNext:@"旅客E"];
        });
        dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(3 * NSEC_PER_SEC)),^{
            [subscriber sendNext:@"旅客F"];
        });
        return nil;
    }] throttle:1] subscribeNext:^(id x) {
        NSLog(@"%@通过了",x);
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

[ [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ subscriber sendNext @H_502_87@: @"旅客A" ] ;

dispatch_after ( dispatch_time ( DISPATCH_TIME_NOW , ( int64_t ) ( 1 @H_502_87@* NSEC_PER_SEC ) ) , dispatch_get_main_queue ( ) , @H_502_87@^ {

[ subscriber sendNext @H_502_87@: @"旅客B" ] ;

} ) ;

dispatch_after ( dispatch_time ( DISPATCH_TIME_NOW , ( int64_t ) ( 2 @H_502_87@* NSEC_PER_SEC ) ) , @H_502_87@^ {

[ subscriber sendNext @H_502_87@: @"旅客C" ] ;

[ subscriber sendNext @H_502_87@: @"旅客D" ] ;

[ subscriber sendNext @H_502_87@: @"旅客E" ] ;

} ) ;

dispatch_after ( dispatch_time ( DISPATCH_TIME_NOW , ( int64_t ) ( 3 @H_502_87@* NSEC_PER_SEC ) ) , @H_502_87@^ {

[ subscriber sendNext @H_502_87@: @"旅客F" ] ;

} ) ;

return nil ;

} ] throttle @H_502_87@: 1 ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"%@通过了" , x ) ;

} ] ;

2015-08-16 22:08:45.677 Test[2618:83764] 旅客A  
2015-08-16 22:08:46.737 Test[2618:83764] 旅客B  
2015-08-16 22:08:47.822 Test[2618:83764] 旅客E  
2015-08-16 22:08:48.920 Test[2618:83764] 旅客F

1

2

3

4

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 08 @H_502_87@: 45.677 Test [ 2618 @H_502_87@: 83764 ] 旅客 A

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 08 @H_502_87@: 46.737 Test [ 2618 @H_502_87@: 83764 ] 旅客 B

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 08 @H_502_87@: 47.822 Test [ 2618 @H_502_87@: 83764 ] 旅客 E

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 08 @H_502_87@: 48.920 Test [ 2618 @H_502_87@: 83764 ] 旅客 F

 [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [[RACSignal interval:1 onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(id x) {
            [subscriber sendNext:@"直到世界的尽头才能把我们分开"];
        }];
        return nil;
    }] takeUntil:[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(5 * NSEC_PER_SEC)),^{
            NSLog(@"世界的尽头到了");
            [subscriber sendNext:@"世界的尽头到了"];
        });
        return nil;
    }]] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

1

2

3

4

5

6

7

8

9

10

11

12

13

14

[ [ [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

[ [ RACSignal interval @H_502_87@: 1 onScheduler @H_502_87@: [ RACScheduler mainThreadScheduler ] ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

[ subscriber sendNext @H_502_87@: @"直到世界的尽头才能把我们分开" ] ;

} ] ;

return nil ;

} ] takeUntil @H_502_87@: [ RACSignal createSignal @H_502_87@: @H_502_87@^ RACDisposable @H_502_87@* ( id <RACSubscriber> subscriber ) {

dispatch_after ( dispatch_time ( DISPATCH_TIME_NOW , ( int64_t ) ( 5 @H_502_87@* NSEC_PER_SEC ) ) , @H_502_87@^ {

NSLog ( @"世界的尽头到了" ) ;

[ subscriber sendNext @H_502_87@: @"世界的尽头到了" ] ;

} ) ;

return nil ;

} ] ] subscribeNext @H_502_87@: @H_502_87@^ ( id x ) {

NSLog ( @"%@" , x ) ;

} ] ;

2015-08-16 22:17:22.648 Test[2766:88737] 直到世界的尽头才能把我们分开  
2015-08-16 22:17:23.648 Test[2766:88737] 直到世界的尽头才能把我们分开  
2015-08-16 22:17:24.645 Test[2766:88737] 直到世界的尽头才能把我们分开  
2015-08-16 22:17:25.648 Test[2766:88737] 直到世界的尽头才能把我们分开  
2015-08-16 22:17:26.644 Test[2766:88737] 直到世界的尽头才能把我们分开  
2015-08-16 22:17:26.645 Test[2766:88737] 世界的尽头到了

1

2

3

4

5

6

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 17 @H_502_87@: 22.648 Test [ 2766 @H_502_87@: 88737 ] 直到世界的尽头才能把我们分开

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 17 @H_502_87@: 23.648 Test [ 2766 @H_502_87@: 88737 ] 直到世界的尽头才能把我们分开

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 17 @H_502_87@: 24.645 Test [ 2766 @H_502_87@: 88737 ] 直到世界的尽头才能把我们分开

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 17 @H_502_87@: 25.648 Test [ 2766 @H_502_87@: 88737 ] 直到世界的尽头才能把我们分开

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 17 @H_502_87@: 26.644 Test [ 2766 @H_502_87@: 88737 ] 直到世界的尽头才能把我们分开

2015 @H_502_87@- 08 @H_502_87@- 16 22 @H_502_87@: 17 @H_502_87@: 26.645 Test [ 2766 @H_502_87@: 88737 ] 世界的尽头到了

ReactiveCocoa学习

代码的四十八手

察值

单边

双边

代理

广播

连接

合并

组合

压缩

映射

归约

过滤

扁平

秩序

命令

延迟

重放

定时

超时

重试

节流

条件

完事

猜你在找的React相关文章