前言
由于时间的问题，暂且只更新这么多了，后续还会持续更新本文《最快让你上手ReactiveCocoa之进阶篇》，目前只是简短的介绍了些RAC核心的一些方法，后续还需要加上MVVM+ReactiveCocoa实战开发。
如果喜欢我的文章，可以关注我，微博:袁峥Seemygo,欢迎交流。也可以来小码哥，了解下我们的iOS培训课程。之后还会更新
1.ReactiveCocoa常见操作方法介绍。
@H_
502_57@
[_textField
.rac_textSignal subscribeNext:^(
id x) {
NSLog(
@"输出:%@",x);
}];
[[_textField
.rac_textSignal bind:^RACStreamBindBlock{
return ^RACStream *(
id value,
BOOL *stop){
return [RACReturnSignal
return:[
NSString stringWithFormat:
@"输出:%@",value]];
};
}] subscribeNext:^(
id x) {
NSLog(
@"%@",x);
}];
flattenMap简单使用
@H_
502_57@
[[_textField
.rac_textSignal flattenMap:^RACStream *(
id value) {
return [RACReturnSignal
return:[
NSString stringWithFormat:
@"输出:%@",value]];
}] subscribeNext:^(
id x) {
NSLog(
@"%@",x);
}];
Map简单使用:
@H_
502_57@
[[_textField
.rac_textSignal map:^
id(
id value) {
return [
NSString stringWithFormat:
@"输出:%@",value];
}] subscribeNext:^(
id x) {
NSLog(
@"%@",x);
}];
@H_
502_57@
RACSubject *signalOfsignals = [RACSubject subject];
RACSubject *signal = [RACSubject subject];
[[signalOfsignals flattenMap:^RACStream *(
id value) {
return value;
}] subscribeNext:^(
id x) {
NSLog(
@"%@aaa",x);
}];
[signalOfsignals sendNext:signal];
[signal sendNext:@
1];
- 1.5 ReactiveCocoa操作方法之组合。
concat:按一定顺序拼接信号，当多个信号发出的时候，有顺序的接收信号。
@H_
502_57@RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
[subscriber sendNext:@
1];
[subscriber sendCompleted];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
[subscriber sendNext:@
2];
return nil;
}];
RACSignal *concatSignal = [signalA concat:signalB];
[concatSignal subscribeNext:^(
id x) {
NSLog(
@"%@",x);
}];
@H_
502_57@
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
[subscriber sendNext:@
1];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
[subscriber sendNext:@
2];
return nil;
}];
RACSignal *mergeSignal = [signalA merge:signalB];
[mergeSignal subscribeNext:^(
id x) {
NSLog(
@"%@",x);
}];
zipWith:把两个信号压缩成一个信号，只有当两个信号同时发出信号内容时，并且把两个信号的内容合并成一个元组，才会触发压缩流的next事件。
@H_
502_57@RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
[subscriber sendNext:@
1];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
[subscriber sendNext:@
2];
return nil;
}];
RACSignal *zipSignal = [signalA zipWith:signalB];
[zipSignal subscribeNext:^(
id x) {
NSLog(
@"%@",x);
}];
-
combineLatest:将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。
@H_502_57@RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@1];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@2];
return nil;
}];
RACSignal *combineSignal = [signalA combineLatestWith:signalB];
[combineSignal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
reduce聚合:用于信号发出的内容是元组，把信号发出元组的值聚合成一个值
@H_502_57@RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@1];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@2];
return nil;
}];
RACSignal *reduceSignal = [RACSignal combineLatest:@[signalA,signalB] reduce:^id(NSNumber *num1,NSNumber *num2){
return [NSString stringWithFormat:@"%@ %@",num1,num2];
}];
[reduceSignal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
@H_502_57@
[_textField.rac_textSignal filter:^BOOL(NSString *value) {
return value.length > 3;
}];
@H_502_57@
[[_textField.rac_textSignal ignore:@"1"] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
distinctUntilChanged:当上一次的值和当前的值有明显的变化就会发出信号，否则会被忽略掉。
@H_502_57@
[[_textField.rac_textSignal distinctUntilChanged] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
RACSubject *signal = [RACSubject subject];
[[signal take:1] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
[signal sendNext:@1];
[signal sendNext:@2];
takeLast:取最后N次的信号,前提条件，订阅者必须调用完成，因为只有完成，就知道总共有多少信号.
RACSubject *signal = [RACSubject subject];
[[signal takeLast:1] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
[signal sendNext:@1];
[signal sendNext:@2];
[signal sendCompleted];
takeUntil:(RACSignal *):获取信号直到某个信号执行完成
@H_502_57@
[_textField.rac_textSignal takeUntil:self.rac_willDeallocSignal];
skip:(NSUInteger):跳过几个信号,不接受。
@H_502_57@
[[_textField.rac_textSignal skip:1] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
switchToLatest:用于signalOfSignals（信号的信号），有时候信号也会发出信号，会在signalOfSignals中，获取signalOfSignals发送的最新信号。
@H_502_57@RACSubject *signalOfSignals = [RACSubject subject];
RACSubject *signal = [RACSubject subject];
[signalOfSignals.switchToLatest subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
[signalOfSignals sendNext:signal];
[signal sendNext:@1];
-
1.7 ReactiveCocoa操作方法之秩序。
doNext: 执行Next之前，会先执行这个Block-
doCompleted: 执行sendCompleted之前，会先执行这个Block
[[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { [subscriber sendNext:@1] [subscriber sendCompleted] return nil }] doNext:^(id x) { // 执行[subscriber sendNext:@1] NSLog(@"doNext") }] doCompleted:^{ // 执行[subscriber sendCompleted] NSLog(@"doCompleted") }] subscribeNext:^(id x) { NSLog(@"%@",x) }]
-
1.8 ReactiveCocoa操作方法之线程。
-
1.9 ReactiveCocoa操作方法之时间。
-
timeout：超时，可以让一个信号在一定的时间后，自动报错。
@H_502_57@RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
return nil;
}] timeout:1 onScheduler:[RACScheduler currentScheduler]];
[signal subscribeNext:^(id x) {
NSLog(@"%@",x);
} error:^(NSError *error) {
NSLog(@"%@",error);
}];
-
interval 定时：每隔一段时间发出信号
[[RACSignal interval:1 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(id x) { NSLog(@"%@",x) }]
-
delay 延迟发送next。
@H_502_57@RACSignal *signal = [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@1];
return nil;
}] delay:2] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
-
1.9 ReactiveCocoa操作方法之重复。
retry重试 ：只要失败，就会重新执行创建信号中的block,直到成功.
@H_
502_57@__block
int i =
0;
[[[RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
if (i ==
10) {
[subscriber sendNext:@
1];
}
else{
NSLog(
@"接收到错误");
[subscriber sendError:
nil];
}
i++;
return nil;
}] retry] subscribeNext:^(
id x) {
NSLog(
@"%@",x);
} error:^(
NSError *error) {
}];
replay重放：当一个信号被多次订阅,反复播放内容
@H_
502_57@RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
[subscriber sendNext:@
1];
[subscriber sendNext:@
2];
return nil;
}] replay];
[signal subscribeNext:^(
id x) {
NSLog(
@"第一个订阅者%@",x);
}];
[signal subscribeNext:^(
id x) {
NSLog(
@"第二个订阅者%@",x);
}];
2.介绍MVVM架构思想。
2.1 程序为什么要架构：便于程序员开发和维护代码。
2.2 常见的架构思想:
-
MVC M:模型 V:视图 C:控制器
-
MVVM M:模型 V:视图+控制器 VM:视图模型
-
MVCS M:模型 V:视图 C:控制器 C:服务类
-
VIPER V:视图 I:交互器 P:展示器 E:实体 R:路由
PS:VIPER架构思想
2.3 MVVM介绍
3.ReactiveCocoa + MVVM 实战一：登录界面
@H_
502_57@/* 需求：1.监听两个文本框的
内容，有
内容才允许按钮点击
2.默认
登录请求.
用MVVM：实现，之前界面的所有业务逻辑
分析：1.之前界面的所有业务逻辑都交给控制器做处理
2.在MVVM架构中把控制器的业务全部搬去VM模型，也就是每个控制器对应一个VM模型.
步骤：1.创建Login
viewmodel类，处理
登录界面业务逻辑.
2.这个类里面应该保存着账号的信息，创建一个账号Account模型
3.Login
viewmodel应该保存着账号信息Account模型。
4.需要时刻监听Account模型中的账号和密码的改变，怎么监听？
5.在非RAC开发中，都是习惯赋值，在RAC开发中，需要改变开发思维，由赋值转变为绑定，可以在一开始初始化的时候，就给Account模型中的
属性绑定，并不需要重写set
方法。
6.每次Account模型的值改变，就需要判断按钮能否点击，在VM模型中做处理，给外界提供一个能否点击按钮的信号.
7.这个
登录信号需要判断Account中账号和密码是否有值，用KVO监听这两个值的改变，把他们聚合成
登录信号.
8.监听按钮的点击，由VM处理，应该给VM声明一个RACCommand，专门处理
登录业务逻辑.
9.执行命令，把数据包装成信号传递出去
10.监听命令中信号的数据传递
11.监听命令的执行时刻
*/
@H_
502_57@
@interface ViewController ()
@property (
nonatomic,
strong) Login
viewmodel *login
viewmodel;
@property (
weak,
nonatomic)
IBOutlet UITextField *accountField;
@property (
weak,
nonatomic)
IBOutlet UITextField *pwdField;
@property (
weak,
nonatomic)
IBOutlet UIButton *loginBtn;
@end
- (Login
viewmodel *)login
viewmodel
{
if (_login
viewmodel ==
nil) {
_login
viewmodel = [[Login
viewmodel alloc] init];
}
return _login
viewmodel;
}
- (
void)bindModel
{
RAC(
self.loginviewmodel.account,account) = _accountField
.rac_textSignal;
RAC(
self.loginviewmodel.account,pwd) = _pwdField
.rac_textSignal;
RAC(
self.loginBtn,enabled) =
self.loginviewmodel.enableLoginSignal;
[[_loginBtn rac_signalForControlEvents:
UIControlEventTouchUpInside] subscribeNext:^(
id x) {
[
self.loginviewmodel.LoginCommand execute:
nil];
}];
}
@H_
502_57@
@interface Loginviewmodel : NSObject
@property (
nonatomic,
strong) Account *account;
@property (
nonatomic,
strong,
readonly) RACSignal *enableLoginSignal;
@property (
nonatomic,
readonly) RACCommand *LoginCommand;
@end
@implementation Loginviewmodel
- (Account *)account
{
if (_account ==
nil) {
_account = [[Account alloc] init];
}
return _account;
}
- (instancetype)init
{
if (
self = [
super init]) {
[
self initialBind];
}
return self;
}
- (
void)initialBind
{
_enableLoginSignal = [RACSignal combineLatest:@[RACObserve(
self.account,account),RACObserve(
self.account,pwd)] reduce:^
id(
NSString *account,
NSString *pwd){
return @(account
.length && pwd
.length);
}];
_LoginCommand = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(
id input) {
NSLog(
@"点击了登录");
return [RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(
0.5 *
NSEC_PER_SEC)),dispatch_get_main_queue(),^{
[subscriber sendNext:
@"登录成功"];
[subscriber sendCompleted];
});
return nil;
}];
}];
[_LoginCommand
.executionSignals.switchToLatest subscribeNext:^(
id x) {
if ([x isEqualToString:
@"登录成功"]) {
NSLog(
@"登录成功");
}
}];
[[_LoginCommand
.executing skip:
1] subscribeNext:^(
id x) {
if ([x isEqualToNumber:@(
YES)]) {
[MBProgressHUD showMessage:
@"正在登录..."];
}
else
{
[MBProgressHUD hideHUD];
}
}];
}
4.ReactiveCocoa + MVVM 实战二：网络请求数据
@H_
502_57@/*
需求：请求豆瓣图书信息，url:https://api.douban.com/v2/book/search?q=基础
分析：请求一样，交给VM模型管理
步骤:
1.控制器提供一个视图模型（reques
viewmodel），处理界面的业务逻辑
2.VM提供一个命令，处理请求业务逻辑
3.在创建命令的block中，会把请求包装成一个信号，等请求成功的时候，就会把数据传递出去。
4.请求数据成功，应该把字典转换成模型，保存到视图模型中，控制器想用就直接从视图模型中
获取。
5.假设控制器想展示
内容到tableView，直接让视图模型成为tableView的数据源，把所有的业务逻辑交给视图模型去做，这样控制器的
代码就非常少了。
*/
@H_
502_57@
@interface ViewController ()
@property (
nonatomic,
weak)
UITableView *tableView;
@property (
nonatomic,
strong) Request
viewmodel *reques
viewmodel;
@end
@implementation ViewController
- (Request
viewmodel *)reques
viewmodel
{
if (_reques
viewmodel ==
nil) {
_reques
viewmodel = [[Request
viewmodel alloc] init];
}
return _reques
viewmodel;
}
- (
void)viewDidLoad {
[
super viewDidLoad];
UITableView *tableView = [[
UITableView alloc] initWithFrame:
self.view.bounds];
tableView
.dataSource =
self.requesviewmodel;
[
self.view addSubview:tableView];
RACSignal *requesSiganl = [
self.requesviewmodel.reuqesCommand execute:
nil];
[requesSiganl subscribeNext:^(
NSArray *x) {
self.requesviewmodel.models = x;
[
self.tableView reloadData];
}];
}
@end
@H_
502_57@
@interface Requestviewmodel : NSObject<UITableViewDataSource>
@property (
nonatomic,
readonly) RACCommand *reuqesCommand;
@property (
nonatomic,
readonly)
NSArray *models;
@end
@implementation Requestviewmodel
- (instancetype)init
{
if (
self = [
super init]) {
[
self initialBind];
}
return self;
}
- (
void)initialBind
{
_reuqesCommand = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(
id input) {
RACSignal *requestSignal = [RACSignal createSignal:^RACDisposable *(
id<RACSubscriber> subscriber) {
NSMutableDictionary *parameters = [
NSMutableDictionary dictionary];
parameters[
@"q"] =
@"基础";
[[AFHTTPRequestOperationManager manager] GET:
@"https://api.douban.com/v2/book/search" parameters:parameters success:^(AFHTTPRequestOperation * _Nonnull operation,
id _Nonnull respon
SEObject) {
NSLog(
@"%@",respon
SEObject);
[subscriber sendNext:respon
SEObject];
[subscriber sendCompleted];
} failure:^(AFHTTPRequestOperation * _Nonnull operation,
NSError * _Nonnull error) {
}];
return nil;
}];
return [requestSignal map:^
id(
NSDictionary *value) {
NSMutableArray *dictArr = value[
@"books"];
NSArray *modelArr = [[dictArr
.rac_sequence map:^
id(
id value) {
return [Book bookWithDict:value];
}] array];
return modelArr;
}];
}];
}
#pragma mark - UITableViewDataSource
- (
NSInteger)tableView:(
UITableView *)tableView numberOfRowsInSection:(
NSInteger)section
{
return self.models.count;
}
- (
UITableViewCell *)tableView:(
UITableView *)tableView cellForRowAtIndexPath:(
NSIndexPath *)indexPath
{
static NSString *ID =
@"cell";
UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:ID];
if (cell ==
nil) {
cell = [[
UITableViewCell alloc] initWithStyle:
UITableViewCellStyleSubtitle reuseIdentifier:ID];
}
Book *book =
self.models[indexPath
.row];
cell
.detailTextLabel.text = book
.subtitle;
cell
.textLabel.text = book
.title;
return cell;
}
@end
本文转载自简书作者袁峥Seemygo 原文
链接：http://www.jianshu.com/p/e10e5ca413b7
