ReactiveCocoa之RACSignal核心类的使用(三)

  RACSignal使用步骤：

  1.创建信号 + (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe

  2.订阅信号,才会激活信号. - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock

  3.发送信号 - (void)sendNext:(id)value

 

 

  RACSignal底层实现：

  1.创建信号，首先把didSubscribe保存到信号中，还不会触发。

  2.当信号被订阅，也就是调用signal的subscribeNext:nextBlock

  2.2 subscribeNext内部会创建订阅者subscriber，并且把nextBlock保存到subscriber中。

  2.1 subscribeNext内部会调用siganl的didSubscribe

  3.siganl的didSubscribe中调用[subscriber sendNext:@1];

  3.1 sendNext底层其实就是执行subscriber的nextBlock

[objc] view
plain copy

// 创建信号  

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

          

          

        // block调用时刻：每当有订阅者订阅信号，就会调用block。  

        // 发送信号  

        [subscriber sendNext:@"ws"];  

        // 如果不在发送数据，最好发送信号完成，内部会自动调用[RACDisposable disposable]取消订阅信号。  

        [subscriber sendCompleted];  

          

          

          

          

          

        // 取消信号，如果信号想要被取消，就必须返回一个RACDisposable  

        // 信号什么时候被取消：1.自动取消，当一个信号的订阅者被销毁的时候机会自动取消订阅，2.手动取消，  

        //block什么时候调用：一旦一个信号被取消订阅就会调用  

        //block作用：当信号被取消时用于清空一些资源  

        return [RACDisposable disposableWithBlock:^{  

              

            // block调用时刻：当信号发送完成或者发送错误，就会自动执行这个block,取消订阅信号。  

              

            // 执行完Block后，当前信号就不在被订阅了。  

            NSLog(@"取消订阅");  

        }];  

    }];  

      

      

      

    // 2. 订阅信号  

    //subscribeNext  

    // 把nextBlock保存到订阅者里面  

    // 只要订阅信号就会返回一个取消订阅信号的类  

    RACDisposable *disposable = [signal subscribeNext:^(id x) {  

          

        // block调用时刻：每当有信号发出数据，就会调用block.  

         NSLog(@"接收到数据:%@",x);  

    }];  

    // 取消订阅  

    [disposable dispose];  

      

 *  RACSignal总结：

 一.核心：

    1.核心：信号类

    2.信号类的作用：只要有数据改变就会把数据包装成信号传递出去

    3.只要有数据改变就会有信号发出

    4.数据发出，并不是信号类发出，信号类不能发送数据

 一.使用方法：

    1.创建信号

    2.订阅信号

 二.实现思路：

    1.当一个信号被订阅，创建订阅者，并把nextBlock保存到订阅者里面。

    2.创建的时候会返回 [RACDynamicSignal createSignal:didSubscribe];

    3.调用RACDynamicSignal的didSubscribe

    4.发送信号[subscriber sendNext:value];

    5.拿到订阅者的nextBlock调用