Front-end
Apple
Apple
  • 第三方库
    • RAC库
      • ReactiveObjc
        • 如何实现的
        • 有关类
        • 有关协议
        • 关键概念列表
          • RACSignal有关类
            • RACStream
              • 头文件定义
            • RACSignal
              • 头文件定义内容
              • 核心代码
              • 常用的方法
                • concat:
                • bind:
                • zipWith 和merge
            • RACSubject
              • 内容
            • RACReplaySubject
              • 内容
            • RACBehaviorSubject
              • 内容
            • RACGroupedSignal
              • 内容
            • RACDynamicSignal
              • RACDynamicSignal
              • RACSignal vs RACDynamicSignal
            • RACReturnSignal
              • 内容
            • RACErrorSignal
            • RACEmptySignal
            • RACChannelTerminal
            • 疑问
              • RACChannelTerminal vs RACSubject
              • RACSignal vs RACStream
              • 热信号和冷信号
                • 进一步理解
              • 信号的发送者和接受者
                • RACSignal 不是信号对象么?为什么信号的发送者是自己呢?
          • RACChannel有关类
            • RACChannel
              • Page 1
              • 用于MVVM架构
              • RAC() vs RACChannelTo()
            • RACKVOChannel
              • 内容
              • 封装了系统的KVO
          • RACCommand
          • RACSubscriber
          • RACTuple
          • RACSequence有关类
          • RACKVOTrampoline
            • NSObject+RACKVOWrapper.h
            • NSObject+RACKVOWrapper.m
          • Page
          • 宏
          • 疑问
            • RACCommand vs RACSignal
            • 有了信号量,为什么还需要RACCommand
        • 操作方法
          • reduce
            • reduce 在不同语言以及库中是否一样的概念?
      • ReactiveSwift
        • 相比ReactiveObjc
      • RxSwift
      • Combine
      • 疑问
        • 热信号 vs 冷信号
        • ReactiveObjC 和 ReactiveSwift 实现原理差异
        • ReactiveObjC、ReactiveCocoa、ReactiveSwift的关系与区别
        • ReactiveObjC、ReactiveCocoa、ReactiveSwift内容
        • ReactiveSwift vs RxSwift
        • RxSwift、ReactiveSwift 和 ReactiveObjC
        • RxSwift、ReactiveSwift 、Combine
    • swift源码
      • 编译
        • 命令参数解释
        • 涉及到的工具
          • cmake 和 ninja
          • sccache
        • Rosetta模式
        • 遇到问题
          • FETCH_HEAD': Permission denied
          • --local_compiler_build': No such file or directory
          • ld: unsupported tapi file type '!tapi-tbd' in YAML file
          • python --version 显示没有这个命令
          • ModuleNotFoundError: No module named 'packaging'
          • ModuleNotFoundError: No module named 'sphinx'
            • sphinx是什么
          • ERROR: Could not find a version that satisfies the requirement sphinx (from versions: none)
          • /Applications/Python\ 3.x/Install\ Certificates.command 失败
          • 已经安装了sphinx,还是显示错误
      • 涉及到的知识点
        • Swift中的MCCAS
Powered by GitBook
On this page
  1. 第三方库
  2. RAC库
  3. ReactiveObjc
  4. 关键概念列表
  5. RACSignal有关类
  6. RACSignal

头文件定义内容

有关方法:

定义了RACSignal类,继承自RACStream,提供了创建和操作异步事件流的方法:

  1. 信号创建:提供多种静态方法创建信号,如createSignal:允许自定义事件发送逻辑;error:、never等用于创建预定义行为的信号。

+createSignal: 创建信号 , 允许在block里面自定义事件发送逻辑。
+error:返回一个RACSignal对象。该信号会立即发送给定的错误(NSError)。如果error参数为nil,则可能返回一个无效的信号。建议将返回值用于进一步的错误处理。
+never  返回一个永远不会完成的RACSignal对象。主要功能:。

+ (RACSignal<ValueType> *)startEagerlyWithScheduler:(RACScheduler *)scheduler block:(void (^)(id<RACSubscriber> subscriber))block; 这个方法还灭有用到,暂时还不理解
+ (RACSignal<ValueType> *)startLazilyWithScheduler:(RACScheduler *)scheduler block:(void (^)(id<RACSubscriber> subscriber))block RAC_WARN_UNUSED_RESULT;

1、startEagerlyWithScheduler:...: 在第一次订阅时立即执行给定的block,并将事件发送给订阅者。无论后续有多少订阅者,block只执行一次。
2、startLazilyWithScheduler:...: 与startEagerlyWithScheduler:...类似,但在每次新订阅时都会重新执行block,并将事件发送给当前订阅者,确保每个订阅者都从头开始接收事件。
两者均接受调度器和发送事件的block作为参数。注意,返回的信号不会自动取消底层订阅。
  1. 和流有关的方法

1)return:

  • 返回一个信号,该信号会立即发送给定的值(value)并完成。

  • 用于创建一个简单的信号,仅包含一个值。

2)empty

  • 返回一个空信号,该信号会立即完成而不发送任何值。

  • 用于表示没有数据传输的信号。

3)typedef RACSignal * _Nullable (^RACSignalBindBlock)(ValueType _Nullable value, BOOL *stop);

定义的一个block类型,用于下面的bind

  • 定义了一个类型别名,表示一个接收值并返回新信号的块。

  • 块参数:

    • value: 可能为 null 的值类型。

    • stop: 一个布尔值指针,设置为 YES 表示终止绑定;NO 则继续。

  • 返回值:可为 null 的信号。

  • 懒惰地将一个块绑定到接收器中的值。

  • 适用于需要提前终止绑定或闭包状态的情况。

  • 参数:

    • block: 一个返回 RACSignalBindBlock 的块,每次重新评估绑定信号时调用。

  • 要求:该块不能为 nil 或返回 nil。

  • 返回值:一个新的信号,代表所有懒惰应用 block 的组合结果。

  • 当源信号完成后,订阅另一个信号。

  • 参数:

    • signal: 需要连接的信号,不能为 nil。

  • 返回值:一个新的信号,依次发送两个信号的所有值。

  • 将接收器中的值与另一个信号中的值组合成 RACTuple。

  • 参数:

    • signal: 需要组合的信号,不能为 nil。

  • 组合方式:第一个 next 值组合,然后第二个 next 值组合,以此类推,直到其中一个信号完成或出错。

  • 返回值:一个新的信号,包含组合后的 RACTuple 值。如果任一原始信号出错,则错误会在返回的新信号中转发。

  1. 操作符:包括flattenMap:(映射并展平)、flatten(合并信号)、map:(映射值)、filter:(过滤值)等常见操作符来转换或筛选信号中的数据。

  1. flattenMap: 将接收器中的值通过block转换为新的信号,并将结果信号合并成一个新信号。

  2. flatten: 合并信号中的信号为单一信号。

  3. map: 将接收器中的每个值通过block进行转换。

  4. mapReplace: 用给定对象替换接收器中的每个值。

  5. filter: 过滤掉不满足block条件的值。

  6. ignore: 过滤掉与给定值相等的值。

  7. reduceEach: 解包接收器中的每个RACTuple并通过reduceBlock映射值。

  8. startWith: 返回一个新的信号,该信号以给定值开始,然后是接收器中的值。

  9. skip: 跳过接收器中的前skipCount个值。

  10. take: 取接收器中的前count个值。

  11. zip: 将多个信号的值组合成RACTuple。

  12. zip...reduce: 将信号组合后通过reduceBlock减少为单个值。

  13. concat: 按顺序连接多个信号。

  14. scanWithStart...reduce: 使用reduceBlock从左到右累积接收器中的值。

  15. scanWithStart...reduceWithIndex: 类似于scanWithStart...reduce,但包含值的索引。

  16. combinePreviousWithStart...reduce: 结合前一个和当前值。

  17. takeUntilBlock: 取值直到predicate返回YES。

  18. takeWhileBlock: 取值直到predicate返回NO。

  19. skipUntilBlock: 跳过值直到predicate返回YES。

  20. skipWhileBlock: 跳过值直到predicate返回NO。

  21. distinctUntilChanged: 返回与前一值不同的值。

  1. 订阅管理:通过subscribe:及其变体方法支持不同场景下的信号订阅与取消订阅。

  • subscribe:

    • 订阅事件,参数为订阅者对象。

  • subscribeNext:

    • 订阅 next 事件,参数为处理 next 事件的 block。

  • subscribeNext:completed:

    • 订阅 next 和 completed 事件,参数分别为处理 next 和 completed 事件的 block。

  • subscribeNext:error:completed:

    • 订阅 next、error 和 completed 事件,参数分别为处理这三种事件的 block。

  • subscribeError:

    • 订阅 error 事件,参数为处理 error 事件的 block。

  • subscribeCompleted:

    • 订阅 completed 事件,参数为处理 completed 事件的 block。

  • subscribeNext:error:

    • 订阅 next 和 error 事件,参数分别为处理这两种事件的 block。

  • subscribeError:completed:

    • 订阅 error 和 completed 事件,参数分别为处理这两种事件的 block。

  1. 调试工具:如logAll、logNext等方法帮助开发者调试信号的行为。

  2. 单元测试辅助:提供了asynchronousFirstOrDefault:、asynchronouslyWaitUntilCompleted:等方法,仅用于单元测试环境中验证信号的行为。

PreviousRACSignalNext核心代码

Last updated 8 months ago

4)

5):

6):

(RACSignal *)bind:(RACSignalBindBlock (^)(void))block
concat
zipWith