ReactiveCocoa 基本使用回忆录

2023-11-07 12:58
文章标签 使用 基本 回忆录 reactivecocoa

本文主要是介绍ReactiveCocoa 基本使用回忆录，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

ReactiveCocoa 基本使用回忆录

RACSignal

//Signal 测试
-(void)testRacSignal{//1 创建信号-默认是冷信号RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {//3 发送数据NSLog(@"信号被订阅");[subscriber sendNext:@100];return nil;}];//2.订阅信号[signal subscribeNext:^(id x) {NSLog(@"信号发送的内容1 %@",x);}];[signal subscribeNext:^(id x) {NSLog(@"信号发送的内容2 %@",x);}];}

//Signal 测试2
-(void)testRacSignal2{//1 创建信号-默认是冷信号RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {//3 发送数据NSLog(@"信号被订阅");self.subscriber = subscriber;[subscriber sendNext:@100];return [RACDisposable disposableWithBlock:^{//只要信号取消订阅就会来这NSLog(@"信号订阅完成");}];}];//2.订阅信号RACDisposable *disposable = [signal subscribeNext:^(id x) {NSLog(@"信号发送的内容 %@",x);}];// 1.创建订阅者,保存nextBlock// 2.订阅信号// 默认一个信号发送数据完毕们就会主动取消订阅.// 只要订阅者在,就不会自动取消信号订阅// 取消订阅信号[disposable dispose]; }

RACSubject

信号提供者，自己可以充当信号，又能发送信号

-(void)RACSubject{//1.创建信号RACSubject *subject = [RACSubject subject];//2.订阅信号[subject subscribeNext:^(id x) {NSLog(@"接收到数据:%@",x);}];//3.发送数据[subject sendNext:@100];}

RACReplaySubject

RACReplaySubject:可以先发送信号,在订阅信号,RACSubject就不可以。

-(void)RACReplaySubject{RACReplaySubject *subject = [RACReplaySubject subject];[subject subscribeNext:^(id x) {NSLog(@"接收到数据:%@",x);}];[subject sendNext:@"LouKit"];}

RACMulticastConnection

用于当一个信号，被多次订阅时，为了保证创建信号时，避免多次调用创建信号中的block，造成副作用，可以使用这个类处理

-(void)RACMulticastConnection{// 1.创建信号// 2.把信号转换成连接类// 3.订阅连接类的信号// 4.连接RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {NSLog(@"信号被订阅");[subscriber sendNext:@100];return nil;}];//把信号转换成链接类// 确定源信号的订阅者RACSubject//    RACMulticastConnection *connection = [signal publish];RACMulticastConnection *connection = [signal multicast:[RACReplaySubject subject]];//订阅信号，也不能激活信号，只是保存订阅者到数组，必须通过连接,当调用连接，就会一次性调用所有订阅者的sendNext:[connection.signal subscribeNext:^(id x) {NSLog(@"订阅者1:%@",x);}];[connection.signal subscribeNext:^(id x) {NSLog(@"订阅者2:%@",x);}];// 4.连接,激活信号[connection connect];
}

RACCommand

RAC中用于处理事件的类，可以把事件如何处理,事件中的数据如何传递，包装到这个类中，可以很方便的监控事件的执行过程。

-(void)RACCommand{// RACCommand:处理事件// RACCommand:不能返回一个空的信号//1.创建命令RACCommand *command = [[RACCommand alloc]initWithSignalBlock:^RACSignal *(id input) {// input:执行命令传入参数// Block调用:执行命令的时候就会调用NSLog(@"input:%@",input);//        return[RACSignal empty];return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"执行命令产生的数据"];return nil;}];}];//2 执行命令RACSignal *signal = [command execute:@1];//3. 订阅信号[signal subscribeNext:^(id x) {NSLog(@"订阅到数据:%@",x);}];
}
-(void)RACCommand2{RACCommand *command = [[RACCommand alloc]initWithSignalBlock:^RACSignal *(id input) {return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"data"];return nil;}];}];// 订阅信号// 注意:必须要在执行命令前,订阅//executionSignals:信号源,信号中信号,signalOfSignals:信号:发送数据就是信号
//    [command.executionSignals subscribeNext:^(RACSignal *x) {
//        [x subscribeNext:^(id x) {
//            NSLog(@"收到的数据:%@",x);
//        }];
//    }];// switchToLatest获取最新发送的信号,只能用于信号中信号[command.executionSignals.switchToLatest subscribeNext:^(id x) {NSLog(@"收到的数据:%@",x);}];[command execute:@1];}
-(void)RACCommand3{// 当前命令内部发送数据完成,一定要主动发送完成// 1.创建命令RACCommand *command = [[RACCommand alloc]initWithSignalBlock:^RACSignal *(id input) {return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"data"];[subscriber sendCompleted];return nil;}];}];[command.executing subscribeNext:^(id x) {if ([x boolValue]) {NSLog(@"当前正在执行");// 当前正在执行}else{// 执行完成/没有执行NSLog(@"执行完成/没有执行");}}];// 2.执行命令[command execute:@1];}

RACTuple、RACSequence

//RACTuple:元组类,类似NSArray,用来包装值.

//RACSequence:RAC中的集合类，用于代替NSArray,NSDictionary,可以使用它来快速遍历数组和字典。

-(void)RACTuple{NSArray *numbers = @[@1,@2,@3,@4];RACTuple *tuple = [RACTuple tupleWithObjectsFromArray:numbers];NSLog(@"tuple:%@",tuple[0]);[numbers.rac_sequence.signal subscribeNext:^(id x) {NSLog(@"%@",x);}];//字典NSDictionary *dict = @{@"key1":@"value1",@"key2":@"value2",@"key3":@100};[dict.rac_sequence.signal subscribeNext:^(RACTuple *tuple) {//       NSString *key = tuple[0];//        NSString *value = tuple[1];// RACTupleUnpack:用来解析元组// 宏里面的参数,传需要解析出来的变量名// = 右边,放需要解析的元组RACTupleUnpack(NSString *key,NSString *value) = tuple;NSLog(@"key:%@,vlaue:%@",key,value);}];}

bind

    [[_textfield.rac_textSignal bind:^RACStreamBindBlock{return ^RACStream*(id value, BOOL *stop){return [RACReturnSignal return:[NSString stringWithFormat:@"LK:%@",value]];};}]subscribeNext:^(id x) {self.lable.text = x;}];

flattenMap

//映射
-(void)flattenMap{//    flattenMap作用:把源信号的内容映射成一个新的信号，信号可以是任意类型。[[_textfield.rac_textSignal flattenMap:^RACStream *(id value) {return [RACReturnSignal return:[NSString stringWithFormat:@"LK:%@",value]];}]subscribeNext:^(id x) {self.lable.text = x;}];
}

map

/**
FlatternMap和Map的区别
1.FlatternMap中的Block返回信号。
2.Map中的Block返回对象。
3.开发中，如果信号发出的值不是信号，映射一般使用Map
4.开发中，如果信号发出的值是信号，映射一般使用FlatternMap。**/
-(void)map{[[_textfield.rac_textSignal map:^id(id value) {return [NSString stringWithFormat:@"LL:%@",value];}]subscribeNext:^(id x) {self.lable.text = x;}];
}

signalOfsignals

-(void)signalOfsignals{RACSubject *signalOfsignals = [RACSubject subject];RACSubject *signal = [RACSubject subject];[[signalOfsignals flattenMap:^RACStream *(id value) {//当signalOfsignals的signals发出信号才会调用return value;}]subscribeNext:^(id x) {NSLog(@"signalOfsignals:%@",x);}];[signalOfsignals sendNext:signal];[signal sendNext:@1];
}

concat

concat:按一定顺序拼接信号，当多个信号发出的时候，有顺序的接收信号。

-(void)concat{//concat:按一定顺序拼接信号，当多个信号发出的时候，有顺序的接收信号。RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"A100"];[subscriber sendCompleted];return nil;}];RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"B100"];[subscriber sendCompleted];return nil;}];// 把signalA拼接到signalB后，signalA发送完成，signalB才会被激活。RACSignal *signal = [signalA concat:signalB];//注意：第一个信号必须发送完成，第二个信号才会被激活[signal subscribeNext:^(id x) {NSLog(@"%@",x);}];}

then

用于连接两个信号，当第一个信号完成，才会连接then返回的信号。
注意使用then，之前信号的值会被忽略掉.

-(void)then{//用于连接两个信号，当第一个信号完成，才会连接then返回的信号。//注意使用then，之前信号的值会被忽略掉.[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@100];[subscriber sendCompleted];return nil;}]then:^RACSignal *{return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@200];[subscriber sendCompleted];return nil;}];}]subscribeNext:^(id x) {NSLog(@"%@",x);//200}];}

merge

把多个信号合并为一个信号，任何一个信号有新值的时候就会调用.

-(void)merge{//把多个信号合并为一个信号，任何一个信号有新值的时候就会调用.RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"A100"];[subscriber sendCompleted];return nil;}];RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"B100"];[subscriber sendCompleted];return nil;}];RACSignal *signal = [signalA merge:signalB];[signal subscribeNext:^(id x) {NSLog(@"%@",x);//200}];
}

zipWith

把两个信号压缩成一个信号，只有当两个信号同时发出信号内容时，并且把两个信号的内容合并成一个元组，才会触发压缩流的next事件

-(void)zipWith{//把两个信号压缩成一个信号，只有当两个信号同时发出信号内容时，并且把两个信号的内容合并成一个元组，才会触发压缩流的next事件RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"A100"];[subscriber sendCompleted];return nil;}];RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"B100"];[subscriber sendCompleted];return nil;}];RACSignal *siganl = [signalA zipWith:signalB];[siganl subscribeNext:^(id x) {NSLog(@"%@",x);//包装成元组发出/**<RACTuple: 0x608000019fb0> (A100,B100)**/}];
}

combineLatest

将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。

-(void)combineLatest{//将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"A100"];[subscriber sendCompleted];return nil;}];RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"B100"];[subscriber sendCompleted];return nil;}];//把两个信号组合成一个信号,跟zip一样，没什么区别RACSignal *siganl = [signalA combineLatestWith:signalB];[siganl subscribeNext:^(id x) {NSLog(@"%@",x);//包装成元组发出/**<RACTuple: 0x608000019fb0> (A100,B100)**/}];
}

reduce

聚合:用于信号发出的内容是元组，把信号发出元组的值聚合成一个值

-(void)reduce{//聚合:用于信号发出的内容是元组，把信号发出元组的值聚合成一个值RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"A100"];[subscriber sendCompleted];return nil;}];RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {[subscriber sendNext:@"B100"];[subscriber sendCompleted];return nil;}];// 常见的用法，（先组合在聚合）。combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock// reduce中的block简介:// reduceblcok中的参数，有多少信号组合，reduceblcok就有多少参数，每个参数就是之前信号发出的内容// reduceblcok的返回值：聚合信号之后的内容。RACSignal *reduceSignal = [RACSignal combineLatest:@[signalA,signalB] reduce:^id(NSNumber *num1 ,NSNumber *num2){return [NSString stringWithFormat:@"%@ %@",num1,num2];}];[reduceSignal subscribeNext:^(id x) {NSLog(@"%@",x);}];}

待续…..

这篇关于ReactiveCocoa 基本使用回忆录的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/363758。

相关文章

Conda与Python venv虚拟环境的区别与使用方法详解

Conda与Python venv虚拟环境的区别与使用方法详解

《Conda与Pythonvenv虚拟环境的区别与使用方法详解》随着Python社区的成长,虚拟环境的概念和技术也在不断发展,：本文主要介绍Conda与Pythonvenv虚拟环境的区别与使用... 目录前言一、Conda 与 python venv 的核心区别1. Conda 的特点2. Python v
阅读更多...
Spring Boot中WebSocket常用使用方法详解

Spring Boot中WebSocket常用使用方法详解

《SpringBoot中WebSocket常用使用方法详解》本文从WebSocket的基础概念出发,详细介绍了SpringBoot集成WebSocket的步骤,并重点讲解了常用的使用方法,包括简单消... 目录一、WebSocket基础概念1.1 什么是WebSocket1.2 WebSocket与HTTP
阅读更多...
C#中Guid类使用小结

C#中Guid类使用小结

《C#中Guid类使用小结》本文主要介绍了C#中Guid类用于生成和操作128位的唯一标识符,用于数据库主键及分布式系统,支持通过NewGuid、Parse等方法生成,感兴趣的可以了解一下... 目录前言一、什么是 Guid二、生成 Guid1. 使用 Guid.NewGuid() 方法2. 从字符串创建
阅读更多...
Python使用python-can实现合并BLF文件

Python使用python-can实现合并BLF文件

《Python使用python-can实现合并BLF文件》python-can库是Python生态中专注于CAN总线通信与数据处理的强大工具,本文将使用python-can为BLF文件合并提供高效灵活... 目录一、python-can 库：CAN 数据处理的利器二、BLF 文件合并核心代码解析1. 基础合
阅读更多...
Python使用OpenCV实现获取视频时长的小工具

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文
阅读更多...
Spring IoC 容器的使用详解(最新整理)

Spring IoC 容器的使用详解(最新整理)

《SpringIoC容器的使用详解(最新整理)》文章介绍了Spring框架中的应用分层思想与IoC容器原理,通过分层解耦业务逻辑、数据访问等模块,IoC容器利用@Component注解管理Bean... 目录1. 应用分层2. IoC 的介绍3. IoC 容器的使用3.1. bean 的存储3.2. 方法注
阅读更多...
Python内置函数之classmethod函数使用详解

Python内置函数之classmethod函数使用详解

《Python内置函数之classmethod函数使用详解》：本文主要介绍Python内置函数之classmethod函数使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录1. 类方法定义与基本语法2. 类方法 vs 实例方法 vs 静态方法3. 核心特性与用法(1编程客
阅读更多...
Linux中压缩、网络传输与系统监控工具的使用完整指南

Linux中压缩、网络传输与系统监控工具的使用完整指南

《Linux中压缩、网络传输与系统监控工具的使用完整指南》在Linux系统管理中,压缩与传输工具是数据备份和远程协作的桥梁,而系统监控工具则是保障服务器稳定运行的眼睛,下面小编就来和大家详细介绍一下它... 目录引言一、压缩与解压：数据存储与传输的优化核心1. zip/unzip：通用压缩格式的便捷操作2.
阅读更多...
使用Python实现可恢复式多线程下载器

使用Python实现可恢复式多线程下载器

《使用Python实现可恢复式多线程下载器》在数字时代,大文件下载已成为日常操作,本文将手把手教你用Python打造专业级下载器,实现断点续传,多线程加速,速度限制等功能,感兴趣的小伙伴可以了解下... 目录一、智能续传：从崩溃边缘抢救进度二、多线程加速：榨干网络带宽三、速度控制：做网络的好邻居四、终端交互
阅读更多...
Python中注释使用方法举例详解

Python中注释使用方法举例详解

《Python中注释使用方法举例详解》在Python编程语言中注释是必不可少的一部分,它有助于提高代码的可读性和维护性,：本文主要介绍Python中注释使用方法的相关资料,需要的朋友可以参考下... 目录一、前言二、什么是注释？示例：三、单行注释语法：以 China编程# 开头，后面的内容为注释内容示例：示例：四
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2