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. RACSubject

内容

RACSubject 是 ReactiveCocoa 框架中的一个核心类,常用于 手动控制事件的发送和处理。它作为 信号(Signal)和订阅者(Subscriber) 的桥梁,允许开发者通过手动发送事件来控制信号流,同时允许多个订阅者接收事件。

RACSubject 的主要特点

  1. 既是信号又是订阅者:RACSubject 既能订阅其他信号,也能作为一个信号被订阅。这种设计让它可以在处理事件的同时,自身也能接收事件。

  2. 手动控制事件发送:通过 sendNext:, sendError:, 和 sendCompleted 这三个方法来发送不同类型的事件。

  3. 多播特性:支持多个订阅者共同接收同一个信号的事件,适合需要广播同一事件给多个观察者的场景。

  4. 热信号:事件发送后,不会缓存给后来的订阅者,这意味着新的订阅者只能接收其订阅后的事件。

RACSubject 的常用方法

  • sendNext::发送一个 next 事件,通常携带一个值,所有的订阅者会收到此事件。

  • sendError::发送一个错误事件,传递一个 NSError 对象给所有订阅者,之后会结束信号。

  • sendCompleted:发送一个完成事件,告知所有订阅者信号已经完成,之后信号将不再发送事件。

使用示例

1. 基本使用

创建一个 RACSubject 并发送一个简单事件:

// 创建一个 RACSubject
RACSubject *subject = [RACSubject subject];

// 订阅信号
[subject subscribeNext:^(id  _Nullable x) {
    NSLog(@"Received value: %@", x);
}];

// 发送事件
[subject sendNext:@"Hello, RACSubject!"];

输出:

Received value: Hello, RACSubject!

在这个例子中,subject 作为信号被订阅,订阅者会在事件发送时收到 "Hello, RACSubject!"。

2. 多个订阅者

RACSubject 支持多个订阅者,每个订阅者都会收到相同的事件:

RACSubject *subject = [RACSubject subject];

// 订阅者 1
[subject subscribeNext:^(id x) {
    NSLog(@"Subscriber 1 received: %@", x);
}];

// 订阅者 2
[subject subscribeNext:^(id x) {
    NSLog(@"Subscriber 2 received: %@", x);
}];

// 发送事件
[subject sendNext:@"Event for both subscribers"];

输出:

Subscriber 1 received: Event for both subscribers
Subscriber 2 received: Event for both subscribers

3. 用于桥接非响应式事件

RACSubject 可以将传统的回调模式转换成响应式信号流。例如,将按钮点击事件转成信号:

@interface MyViewController : UIViewController
@property (nonatomic, strong) RACSubject *buttonClickSubject;
@end

@implementation MyViewController

- (instancetype)init {
    self = [super init];
    if (self) {
        // 初始化 RACSubject
        self.buttonClickSubject = [RACSubject subject];
    }
    return self;
}

// 按钮点击事件
- (void)buttonClicked {
    // 手动发送事件
    [self.buttonClickSubject sendNext:@"Button clicked"];
}

@end

// 其他类中订阅此事件
MyViewController *vc = [[MyViewController alloc] init];
[vc.buttonClickSubject subscribeNext:^(id x) {
    NSLog(@"Received button click event: %@", x);
}];

// 模拟按钮点击
[vc buttonClicked];

输出:

Received button click event: Button clicked

RACSubject 和 RACReplaySubject 的区别

  1. RACSubject:不缓存发送的事件,只有当前的订阅者可以接收到事件。

  2. RACReplaySubject:会缓存一定数量的事件,新订阅者可以接收之前缓存的事件。

如果希望新的订阅者能够接收到之前发送的事件,使用 RACReplaySubject 更合适。

适用场景

  • 桥接传统回调:将非响应式的事件(如代理、回调等)转换成响应式信号。

  • 广播事件:需要向多个订阅者发送相同事件时,RACSubject 可以作为广播工具。

  • 手动控制事件发送:适用于需要手动触发事件的场景。

总结

RACSubject 是 ReactiveCocoa 中灵活、常用的信号类型之一。它结合了信号和订阅者的特点,适合用于需要手动控制事件、将传统回调桥接成信号流的场景,在响应式编程中提升代码的简洁性和可读性。

PreviousRACSubjectNextRACReplaySubject

Last updated 8 months ago