当前位置: 首页 > 编程日记 > 正文

ReactiveCocoa代码实践之-更多思考

三.ReactiveCocoa代码实践之-更多思考

1. RACObserve()宏形参写法的区别

之前写代码考虑过 RACObserve(self.timeLabel , text) 和 RACObserve(self , timeLabel.text) 的区别。 因为这两种方法都是观察self.timeLabel.text的属性,并且都能实现功能。估计是作者原本用的其中一种后来对另一种也提供了支持,究竟有什么区别哪一种写法更好?

点进去看RACObserve的源码 大多都是方法调用,一层一层点进去最后来到这个方法。

- (RACDisposable *)rac_observeKeyPath:(NSString *)keyPath options:(NSKeyValueObservingOptions)options observer:(__weak NSObject *)weakObserver block:(void (^)(id, NSDictionary *, BOOL, BOOL))block

这个方法里面把逗号后面的keypath通过“.” 进行分割成了一个数组。 并且得到三个属性

BOOL keyPathHasOneComponent = (keyPathComponents.count == 1);
NSString *keyPathHead = keyPathComponents[0];
NSString *keyPathTail = keyPath.rac_keyPathByDeletingFirstKeyPathComponent;

这里会取到keypatch的头和去掉头的部分,并且会在下面方法内部自己调用自己

// Adds the callback block to the remaining path components on the value. Also
// adds the logic to clean up the callbacks to the firstComponentDisposable.
void (^addObserverToValue)(NSObject *) = ^(NSObject *value) {RACDisposable *observerDisposable = [value rac_observeKeyPath:keyPathTail options:(options & ~NSKeyValueObservingOptionInitial) observer:weakObserver block:block];[firstComponentDisposable() addDisposable:observerDisposable];
};

并且把keyPathTail 作为keypatch传进去了,就是递归调用,每一次进来都会切掉第一个元素,直到BOOL keyPathHasOneComponent 这个值等于yes。从这个角度看用RACObserve(self , timeLabel.text) 这种写法会引发递归调用,性能不如RACObserve(self.timeLabel.text)。

更多RAC宏相关知识可见这篇 :http://blog.sunnyxx.com/2014/03/06/rac_1_macros/

2.集合操作

假设现在有一个需求,有一串密码的数组,我们判断密码长度小于6位就是太短,就会系统内部抛出一个消息:XXX密码太短不合格。采用RAC的写法会比常规写法方便,一个过滤一个自定义然后直接返回。

NSArray *pwds = @[@"567887",@"89877",@"789",@"7899000"];
RACSequence *results = [[pwds.rac_sequencefilter:^ BOOL (NSString *pwd) {return pwd.length < 6;}]map:^id(NSString *pwd) {return [[pwd mutableCopy]stringByAppendingString:@"密码太短不合格"];}];
NSLog(@"%@",results.array);

中间filter方法的block内代码会在下面results.array代码执行时才会执行, 相当于是有了个订阅者才会执行。这一点和RACSignal很像,因为signal 和 sequence 都是streams,他们共享很多相同的方法signal是push驱动的stream,sequence是pull驱动的stream。

如果相从RACSequence对象中取出其他属性时进行操作也可以用如下方法

RACSequence *s = [RACSequence sequenceWithHeadBlock:^id{return @"自定义操作";
} tailBlock:^RACSequence *{return [RACSequence new];
}];
NSLog(@"%@",s.head);
NSLog(@"%@",s.tail);

两个block分别会在指定属性被调用时才会执行,注意head就是sequence的第一个元素,而tail是除去第一个元素的剩余所有,所以还是一个sequence。(董铂然博客园)

3.信号实现游戏技能释放

假设现在需要用RAC模拟一个街机里放爆气技能的方法。 按下了指定的按钮顺序下前下前拳就会释放绝招。

首先需要将各个按钮连线,并设置一个信号来监听所有按键单独信号的并集,捕捉到每个按钮的title。

// 把六个按键的信号合并
RACSignal *comboSignal = [[RACSignal merge:@[[self.topBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.bottomBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.leftBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.rightBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.BBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.ABtn rac_signalForControlEvents:UIControlEventTouchUpInside]]]
map:^id(UIButton *btn) {return btn.currentTitle;
}];

然后对这个信号源进行buffer操作,把每三秒收到的所有按键信息都捕获到,并进行判断和后继操作

// 设置触发爆气条件
NSString *comboCode = @"下前下前拳";
// 实际操作
RACSignal *canAction = [[[comboSignal bufferWithTime:3 onScheduler:[RACScheduler mainThreadScheduler]] map:^id(RACTuple *value) {return [[value allObjects] componentsJoinedByString:@""];
}] map:^id(NSString *value) {return @([value containsString:comboCode]);
}];
// 调用combo:方法就是技能释放
[self rac_liftSelector:@selector(combo:) withSignalsFromArray:@[canAction]];

上面的代码可以实现预计的功能,只要你能在三秒的buffer内按出指定的按键就能释放。但是用这个方法中间也有一个问题:设置了buffer3秒后这个block里面每隔三秒才会来到一次,也就是说如果你在0.5秒内就按出了技能,那也需要再等2.5秒才能放出技能,显然这个在实战中是不能接受的。

于是尝试了其他的实现思路,尝试了takeLast:及takeUntilBlock:及scanWithStart: 等方法都不是很合适,最后使用了aggregateWithStart:  达到了需求的目的。

// 设置触发爆气条件
NSString *comboCode = @"下前下前拳";
// 实际操作
_time = [[[NSDate alloc] init] timeIntervalSince1970];
[[comboSignal aggregateWithStart:@"" reduce:^id(NSString* running, NSString* next) {if (([[[NSDate alloc] init] timeIntervalSince1970] - _time) < 3){NSString *str = [NSString stringWithFormat:@"%@%@",running,next];return [str containsString:comboCode]?[self combo]:str;}_time = [[[NSDate alloc] init] timeIntervalSince1970];return str.length < combo.length ? str : [str subStringFromIndex:str.length - comboCode.length];
}]subscribeNext:^(id x){
}];

使用这段代码可以在满足之前条件的前提下,并且按钮一按完马上触发技能。

aggregateWithStart:reduce:的第一个参数是初始值,第二个参数是一个block,这个block的返回值就是下一次来到这个block的 running参数。我在这个block的循环中做的操作有:

1.对时间进行delta计算,如果距离上一次时间节点大于3秒,刷新时间节点重新计时。 str小于5则返回,大于5则截取后五位返回。

2.如果小于3秒则把每次按键信息聚合成一个字符串并判断是否包含技能触发代码。

3.满足的话触发技能,技能方法的内部也刷新了时间节点,并截取running(保留最后4位,防止上一个循环结束和下一个循环开始所满足的条件)。不满足则将这个字符串继续返回。

虽然代码写的不是很好看,但是功能是实现了,感觉有点别扭,因为函数式编程倡导的是引用透明无副作用,所以上面需要记录值和成员变量的做法很明显就不适合用RAC了,应该还会有更好的方法实现。

4.其他RAC操作

1)映射:flattenMap,Map用于把源信号内容映射成新的内容

2)组合:concat:按一定顺序拼接信号,当多个信号发出的时候,有顺序的接收信号

3)`then`:用于连接两个信号,当第一个信号完成,才会连接then返回的信号

4)`merge`:把多个信号合并为一个信号,任何一个信号有新值的时候就会调用

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

6)`reduce`聚合:用于信号发出的内容是元组,把信号发出元组的值聚合成一个值

7)filter:过滤信号,使用它可以获取满足条件的信号.

8) ignore:忽略完某些值的信号.

9) distinctUntilChanged:当上一次的值和当前的值有明显的变化就会发出信号,否则会被忽略掉

10) take:从开始一共取N次的信号

11)takeLast:取最后N次的信号,前提条件,订阅者必须调用完成,因为只有完成,就知道总共有多少信号

12)takeUntil:(RACSignal *):获取信号直到某个信号执行完成

13)skip:(NSUInteger):跳过几个信号,不接受

14)switchToLatest:用于signalOfSignals(信号的信号),有时候信号也会发出信号,会在signalOfSignals中,获取signalOfSignals发送的最新信号

15)doNext: 执行Next之前,会先执行这个Block

16)doCompleted: 执行sendCompleted之前,会先执行这个Block

17)deliverOn: 内容传递切换到制定线程中,副作用在原来线程中,把在创建信号时block中的代码称之为副作用

18)subscribeOn: 内容传递和副作用都会切换到制定线程中

19)interval 定时:每隔一段时间发出信号

20)delay 延迟发送next。

21) 代替代理:

  • rac_signalForSelector:用于替代代理。

22) 代替KVO :

  • rac_valuesAndChangesForKeyPath:用于监听某个对象的属性改变。

23) 监听事件:

  • rac_signalForControlEvents:用于监听某个事件。

24) 代替通知:

  • rac_addObserverForName:用于监听某个通知。

25) 监听文本框文字改变:

  • rac_textSignal:只要文本框发出改变就会发出这个信号。

26) 处理当界面有多次请求时,需要都获取到数据时,才能展示界面

  • rac_liftSelector:withSignalsFromArray:Signals:当传入的Signals(信号数组),每一个signal都至少sendNext过一次,就会去触发第一个selector参数的方法。
  • 使用注意:几个信号,参数一的方法就几个参数,每个参数对应信号发出的数据

RAC曾经被冠以 学习成本搞,可读性差,debug的噩梦等不良评价,但随着近几年的演变已逐渐被企业级项目所接受,并且成为函数响应式编程主流框架。RAC用人越来越多,随笔和博客也越来越多,学习的门槛已经大大降低。 并且我觉得初学者没有必要一开始就把所有操作和概念都弄懂,可以从简单的用法开始一步步的接触高阶语法,这样会更容易接受。

转载于:https://www.cnblogs.com/dsxniubility/p/5372370.html

相关文章:

Java常用命令及Java Dump

线程Dump,包含所有线程的运行状态。纯文本格式。 堆Dump,包含线程Dump,幵包含所有堆对象的状态。二进制格式。 Java Dump方法 1.使用Java虚拟机制作Dump 指示虚拟机在发生内存不足错误时,自动生成堆Dump -XX:HeapDumpOnOutOfMemoryError 2.使用图形化工具制作Dump 使用JDK…

使用Windows远程登录Ubuntu

一、SSH登录 1、Ubuntu默认没有安装SSH &#xff0c;可以在新得利软件安装程序里&#xff0c;搜索SSH&#xff0c;标记并安装&#xff1b; 或者使用命令&#xff1a; sudo apt-get install openssh-server sudo /etc/init.d/ssh restart ssh localhost…

紧急更新下降难度,《王者荣耀》绝悟 AI 难倒一片玩家

作者 | 神经星星来源 | HyperAI超神经&#xff08;ID: HyperAI&#xff09;在 5 月 1 日~ 5 月 4 日期间&#xff0c;玩家通过《王者荣耀》最新版本客户端进入游戏&#xff0c;即可与绝悟 AI 对战。一时间哀鸿遍野&#xff0c;普通玩家、游戏主播、职业选手&#xff0c;纷纷表示…

SQL:安装多个实例,修改实例端口号,和IP加端口号连接实例

原文:SQL&#xff1a;安装多个实例&#xff0c;修改实例端口号,和IP加端口号连接实例sql server 安装第一个实例&#xff0c;默认实例的端口是1433&#xff0c; 一个库中如果有多个实例&#xff0c;从第二个实例开始的端口是动态端口&#xff0c;需要的话&#xff0c;自己手工指…

用“逐步排除”的方法定位Java服务线上“系统性”故障

说明&#xff1a;原文地址已经不可访问&#xff0c;其他地方有转载&#xff0c;不过很多丢失图片&#xff0c;所以&#xff0c;找到一处有图的重新配好图。 用“逐步排除”的方法定位Java服务线上“系统性”故障 Posted on 2014/08/25李斯宁&#xff08;高级测试开发工程师&…

清华硕士爆料:这些才是机器学习必备的数学基础

现如今&#xff0c;计算机科学、人工智能、数据科学已成为技术发展的主要推动力。无论是要翻阅这些领域的文章&#xff0c;还是要参与相关任务&#xff0c;你马上就会遇到一些拦路虎&#xff1a;想过滤垃圾邮件&#xff0c;不具备概率论中的贝叶斯思维恐怕不行&#xff1b;想试…

LINUX环境下资源下载中文目录及中文文件名称问题

为什么80%的码农都做不了架构师&#xff1f;>>> http://www.yeeach.com/2009/04/09/linux%E7%8E%AF%E5%A2%83%E4%B8%8B%E8%B5%84%E6%BA%90%E4%B8%8B%E8%BD%BD%E4%B8%AD%E6%96%87%E7%9B%AE%E5%BD%95%E5%8F%8A%E4%B8%AD%E6%96%87%E6%96%87%E4%BB%B6%E5%90%8D%E7%A7%B…

dojo从asp.net中获取json数据

搞来有搞去终于有了个结果&#xff0c;主要是一开始犯了一些低级错误。 对于json不太了解的童鞋&#xff0c;可以看看这个&#xff1a;http://www.dreamdu.com/blog/2008/10/19/json_in_javascript/ 这个例子中主要是从数据库中读取数据&#xff0c;转换成JSON格式&#xff0c;…

RHEL5 install

RHEL5 安装转载于:https://blog.51cto.com/bhanv/477708

线上java问题排查

0.jps 这个输出java进程pid #jps 查看java的线程 #top -Hp 25448 如图25757这个线程比较耗时&#xff0c;看看他在做什么 注意需要折算出线程pid的16进制值&#xff0c;然后jstack。 可以打印更多信息 #jstack pid | grep -A 20 649d 参考&#xff1a;JVM调优之jstack找出…

GitHub标星10,000+,Apache项目ShardingSphere的开源之路

【编者按】几天前&#xff0c;当 GitHub 全球产品技术生态总经理 Michael Francisco 谈到中国开发者已经成为 GitHub 上最活跃的群体时&#xff0c;有开发者提出数量之后质量也要跟上。的确&#xff0c;过去十数年间&#xff0c;中国开源一直呈现企业热使用热社区冷开发冷的景象…

JAVA中LOCK

原文链接&#xff1a;http://www.cnblogs.com/dolphin0520/p/3923167.html 一.synchronized的缺陷 我们知道如果一个代码块被synchronized修饰了&#xff0c;当一个线程获取了对应的锁&#xff0c;并执行该代码块时&#xff0c;其他线程便只能一直等待&#xff0c;等待获取锁的…

【公开课预告】AutoML知多少

5月7日周四19:00&#xff0c;商汤泰坦公开课第010期&#xff0c;论文解读系列课程第二期即将开播&#xff01;我们邀请到商汤科技的4位研究员&#xff0c;分享团队在AutoML方面的一系列研究工作&#xff0c;其中包含CVPR 2020、ICLR 2020等多篇最新论文成果&#xff0c;想要了解…

Linux kernel futex.c的bug导致JVM不可用

JVM死锁导致线程不可用&#xff0c;然后会瞬间起N个线程&#xff0c;当然也是不可用的&#xff0c;因为需要的对象死锁&#xff0c;然后耗尽文件句柄导致外部TCP无法建议拒绝服务&#xff0c;jstack之后就会恢复。 解决办法&#xff1a;替换中间件类库 &#xff0c;比如httpcli…

ruby爬虫综述

http://ihower.tw/blog/archives/2941一个ruby爬虫的例子http://hi.baidu.com/anspider/blog/item/9da210425a0e4e179213c6fb.html

Exchange 2016集成ADRMS系列-12:域内outlook 2010客户端测试

接下来&#xff0c;我们来到域内安装了office 2010的机器上进行测试。 首先我们在客户端上强制刷新组策略&#xff0c;把我们刚才设置的策略刷新下来。 然后我们可以运行gpresult /h result.html来看看策略是不是已经下来了。 策略下来之后&#xff0c;我们打开客户端上面的out…

在Linux下编写Daemon

在Linux下编写Daemon 转自&#xff1a;http://blog.163.com/prevBlogPerma.do?hostmanyhappy163&srl1644768312010718111142260&modeprev 在Linux&#xff08;以Redhat Linux Enterprise Edition 5.3为例&#xff09;下&#xff0c;有时需要编写Service。Service也是…

JVM虚拟机参数配置官方文档

JDK8 https://docs.oracle.com/javase/8/docs/technotes/tools/unix/java.html https://docs.oracle.com/javase/8/docs/technotes/guides/vm/gctuning/index.html JDK7 https://docs.oracle.com/javase/7/docs/technotes/tools/solaris/java.html 官方博客 https://blogs.or…

在Rust代码中编写Python是种怎样的体验?

作者 | Mara Bos&#xff0c;Rust资深工程师译者 | Arvin&#xff0c;编辑 | 屠敏来源 | CSDN&#xff08;ID&#xff1a;CSDNnews&#xff09;大约一年前&#xff0c;我发布了一个名为inline-python&#xff08;https://crates.io/crates/inline-python&#xff09;的Rust类库…

Docker配置指南系列(二):指令集(二)

pause: 停止一个容器的所有进程语法&#xff1a;ocker pause CONTAINER [CONTAINER...] port: 列出容器的端口映射&#xff0c;或者查看指定开放端口的NAT映射语法&#xff1a;docker port [--help] CONTAINER [PRIVATE_PORT[/PROTO]] ps: 列出容器语法&#xff1…

无需训练RNN或生成模型,我写了一个AI来讲故事

作者 | Andre Ye译者 | 弯月出品 | AI科技大本营&#xff08;ID&#xff1a;rgznai100&#xff09;这段日子里&#xff0c;我们都被隔离了&#xff0c;就特别想听故事。然而&#xff0c;我们并非对所有故事都感兴趣&#xff0c;有些人喜欢浪漫的故事&#xff0c;他们肯定不喜欢…

Java字节码instrument研究

MyAgent项目 <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation"http://maven.apache.org/POM/4.…

怎样保持良好的心态

有一位朋友有一次气冲冲的跟我说&#xff1a;“气死我了&#xff01;我刚刚发现我一位员工出了错&#xff0c;令产品出现了质量的问题&#xff0c;我修理了他一顿。。。 我问&#xff1a;”你认为你的生产流程里面可能一点错误都没有吗&#xff1f;“ 他说&#xff1a;”应该不…

web编程速度大比拼(nodejs go python)(非专业对比)

C10K问题的解决&#xff0c;涌现出一大批新框架&#xff0c;或者新语言&#xff0c;那么问题来了:到底谁最快呢&#xff1f;非专业程序猿来个非专业对比。 比较程序&#xff1a;输出Hello World&#xff01; 测试程序&#xff1a;siege –c 100 –r 100 –b 例子包括&#xff1…

linux邮件服务

邮件服务要求:l 能够构建完整的邮件系统 能够正确设置DNS邮件服务器记录 l 能够配置sendmail服务器 设置客户端软件使用邮件服务器 准备工作&#xff1a; l 主机名&#xff1a;srv.benet.com /etc/sysconfig/network <永久的> l 域名 正向区域 bt.com完成NDS的…

MaskFlownet:基于可学习遮挡掩模的非对称特征匹配丨CVPR 2020

来源 | 微软研究院AI头条&#xff08;ID: MSRAsia&#xff09;编者按&#xff1a;在光流预测任务中&#xff0c;形变带来的歧义与无效信息会干扰特征匹配的结果。在这篇 CVPR 2020 Oral 论文中&#xff0c;微软亚洲研究院提出了一种可学习遮挡掩模的非对称特征匹配模块 &#x…

GDB调试--以汇编语言为例

#rpm -qa |grep gdb 下载&#xff1a; 安装 #tar -zxvf #./configure #make 使用GDB 以汇编语言调试为例 汇编语言实现CPUID指令 CPUID cpuid是Intel Pentinum以上级CPU内置的一个指令&#xff08;486级以下的CPU不支持&#xff09;&#xff0c;他用于识别某一类型…

汇编语言系统调用过程

以printf为例&#xff0c;详细解析一个简单的printf调用里头&#xff0c;系统究竟做了什么&#xff0c;各寄存器究竟如何变化。 如何在汇编调用glibc的函数&#xff1f;其实也很简单&#xff0c;根据c convention call的规则&#xff0c;参数反向压栈&#xff0c;call&#xf…

switch语句中在case块里声明变量会遇到提示“Expected expression before...的问题

switch语句中在case块里声明变量会遇到提示“Expected expression before..."的问题 例如在如下代码中 1case constant:2 int i 1;3 int j 2;4 self.sum i j;5 break;GCC在case语句之后的第一行中声明变量时遇到问题。 这时需要在case块两端添加花括号&am…

帮AI体检看病一条龙服务,阿里发布“AI安全诊断大师”

如同一些出生免疫力就有缺陷的人一样&#xff0c;AI也存在免疫力缺陷。基于从源头打造安全免疫力的新一代安全架构理念&#xff0c;最近&#xff0c;阿里安全研究发布了一项核心技术“AI安全诊断大师”&#xff0c;可对AI模型全面体检&#xff0c;“看诊开方”&#xff0c;让AI…