了解几个概念

• 通过RACSignal创建一个信号 (默认是 冷信号)
• 通过订阅者订阅这个信号!(变成 热信号)
• RACSubscriber(协议):订阅者(发送信号)
• RACDisposable:它可以帮助我们取消订阅
  • 默认一个信号发送数据完毕就会主动取消订阅
  • 只要订阅者在,就不会自动取消订阅

基本使用的代码样例

#import "ViewController.h"
#import <ReactiveObjC/ReactiveObjC.h>

@interface ViewController ()

/// 订阅者
@property (strong, nonnull, nonatomic) id<RACSubscriber> subscriber;

@end

@implementation ViewController

- (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event {
    
 
    // 1.创建信号(这是一个冷信号)
    // didSubscribe调用:只要一个信号被订阅就会调用!
    // didSubscribe作用:利用subscriber发送数据!

 __weak typeof(self) weakSelf = self;

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        NSLog(@"come here");
        
        // 3.发送信号
        [subscriber sendNext:@"RAC的RACSignal"];
        
        // 引用订阅者, 防止自动取消订阅
        weakSelf.subscriber = subscriber;r = subscriber;
        
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"信号取消订阅, 释放资源");
        }];
    }];
    
    // 2.订阅信号(冷信号 -> 热信号)
    // nextBlock调用:只要订阅者 发送数据 就会调用!
    // nextBlock作用: 处理数据, 展示UI界面等!
    RACDisposable *disposaable = [signal subscribeNext:^(id  _Nullable x) {
       
        // 信号中的内容
        NSLog(@"信号中发内容是: %@", x);
        
    }];
    
    // 注意: 默认一个信号发送数据完毕就会主动取消订阅
    // 只要订阅者在,就不会自动取消订阅
    // 手动取消订阅
    [disposaable dispose];
}

@end

过程分析

RACSignal.png

• 信号的创建

// RACSignal
// 信号创建
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
    return [RACDynamicSignal createSignal:didSubscribe];
}

// 这个方法的底层是如下的实现
//  RACDynamicSignal
/*
    这个方法做了两件事情:
        1> 创建信号 signal
        2> 将方法中的 didSubscribe 参数 进行保存
*/

// RACDynamicSignal
// The block to invoke for each subscriber.
@property (nonatomic, copy, readonly) RACDisposable * (^didSubscribe)(id<RACSubscriber> subscriber);

+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
    RACDynamicSignal *signal = [[self alloc] init];
    
    // 保存  didSubscribe
    signal->_didSubscribe = [didSubscribe copy];
    
    return [signal setNameWithFormat:@"+createSignal:"];
}

• 信号的订阅

// RACSignal
/*
    订阅信号也做了两件事
        1> 创建订阅者  RACSubscriber *o
            在内部 保存了 nextBlock
                
        2> 订阅信号     
*/ 
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
    NSCParameterAssert(nextBlock != NULL);

    // 创建一个真正的订阅者
    RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
    
    // 订阅信号 
    return [self subscribe:o];
}

//  RACSubscriber ==== 创建订阅者 

// These callbacks should only be accessed while synchronized on self.
@property (nonatomic, copy) void (^next)(id value);
@property (nonatomic, copy) void (^error)(NSError *error);
@property (nonatomic, copy) void (^completed)(void);

// 创建订阅者
+ (instancetype)subscriberWithNext:(void (^)(id x))next error:(void (^)(NSError *error))error completed:(void (^)(void))completed {
    RACSubscriber *subscriber = [[self alloc] init];

    subscriber->_next = [next copy]; // 保存
    subscriber->_error = [error copy];
    subscriber->_completed = [completed copy];

    return subscriber;
}

// RACDynamicSignal 
// 订阅信号
- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
    NSCParameterAssert(subscriber != nil);

    RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable];
    subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];

    if (self.didSubscribe != NULL) {
        RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{
            
            // 执行 创建信号时保存的 didSubscribe  -> 回到测试代码
            RACDisposable *innerDisposable = self.didSubscribe(subscriber);
            
            [disposable addDisposable:innerDisposable];
        }];

        [disposable addDisposable:schedulingDisposable];
    }
    
    return disposable;
}

• 信号的发送

// 上一步,中代码会执行我们创建信号时的 didSubscribe
// 在源代码中, 我们进行了发送信号的操作
// 它的内部 其它是在执行订阅者中的处理

// RACSubscriber
- (void)sendNext:(id)value {
    @synchronized (self) {
        void (^nextBlock)(id) = [self.next copy];
        if (nextBlock == nil) return;

        nextBlock(value); // 执行源代码中的回调处理UI等等.
    }
}