iOS端RAC 两大框架 ReactiveObjC 和 ReactiveSwift 使用方法可以看SDK
使用
RAC 的核心思想:创建信号 - 订阅信号 - 发送信号 ,并且在 RAC 中有大量的 block ,所以使用RAC之前你需要熟悉Block的使用。
1. RACSignal 信号
//创建信号量
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
/* 发送信号 */
[subscriber sendNext:@"信号量发送"];
return nil;
}];
//信号量订阅
RACDisposable *disposable = [signal subscribeNext:^(id _Nullable x) {
NSLog(@"信号量:%@", x);
}];
/*
*信号量订阅取消,
*注:
* 1、你在一个视图控制器创建信号量时,在生命周期结束的时候,需要取消订阅,否则会造成内存泄漏
* 2、当你在一个多次创建订阅的时候,会收到多个订阅,所以你需要自己管理信号量的创建和取消
*/
[disposable dispose];
2. RACSubject 信号
同代理方法类似
// 创建信号
RACSubject *subject = [RACSubject subject];
// 发送信号
[subject sendNext:@"发送的内容"];
// 和代理、block 类似
[subject subscribeNext:^(id _Nullable x) {
NSLog(@"接受到的内容:%@", x);
}];
3.遍历 Array 和 Dictionary
//遍历 array
NSArray *array = @[@"a", @"b", @"c", @"d", @"e"];
[array.rac_sequence.signal subscribeNext:^(id _Nullable x) {
NSLog(@"数组内容:%@", x);
}];
//遍历dic
NSDictionary *dictionary = @{@"key1":@"value1", @"key2":@"value2", @"key3":@"value3"};
[dictionary.rac_sequence.signal subscribeNext:^(RACTuple * _Nullable x) {
RACTupleUnpack(NSString *key, NSString *value) = x; // x 是一个元祖
NSLog(@"字典内容:%@:%@", key, value);
}];
//map 函数
NSArray *array = @[@1, @2, @3, @4, @5];
NSArray *newArray = [[array.rac_sequence map:^id _Nullable(id _Nullable value) {
NSLog(@"数组内容:%@", value);
return value > 3; // 通过map函数,设定一个条件,对数组进行操作,可以是筛选出满足对应条件的所有值
//return value%2 == 0; 筛选出偶数
}] array];
//mapReplace
NSArray *array = @[@"1", @"2", @"3", @"4", @"5"];
NSArray *newArray = [[array.rac_sequence mapReplace:@"0"] array]; // 将所有内容替换为 0
4. 监听点击事件
[[button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
NSLog(@"%@ 按钮被点击了", x); // x 是 button 按钮对象
}];
RAC(_loginButton, enabled) = [RACSignal combineLatest:@[_username.rac_textSignal, _password.rac_textSignal] reduce:^id _Nullable(NSString * username, NSString * password){
return @(username.length && password.length);
}];
5.监听 Notification 通知事件
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:@"notificationNameString" object:nil] subscribeNext:^(NSNotification * _Nullable x) {
NSLog(@"%@ 收到通知", x);
}];
6. 监听 TextField
[[textField rac_textSignal] subscribeNext:^(NSString * _Nullable x) {
NSLog(@"输入框内容:%@", x);
}];
//添加监听条件
[[textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
return value.length > 6; // 条件判断,满足此处条件才会执行下面的block
}] subscribeNext:^(NSString * _Nullable x) {
NSLog(@"输入框内容:%@", x);
}];
7. 代替 Delegate 、KVO、计时器
//delegate
[[view rac_signalForSelector:@selector(btnClick)] subscribeNext:^(RACTuple * _Nullable x) {
NSLog(@" view 中的按钮被点击了");
}];
//kvo
//此处多次调用会多次创建,如果需要释放 用RACDisposable *racdip 接收,然后在适当的时机下释放[racdip dispose]
[RACObserve(view, data) subscribeNext:^(id _Nullable x) {
NSLog(@"属性的改变:%@", x); // x 是监听属性的改变结果,不能监听数组和字典的改变
}];
//nstime
@interface ViewController ()
@property (nonatomic, strong) RACDisposable *dsp;
@end
/* 定义计时器监听 */
_dsp = [[RACSignal interval:1.0 onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(NSDate * _Nullable x) {
NSLog(@"当前时间:%@", x); // x 是当前的系统时间
/* 关闭计时器 */
[_dsp dispose];
}];