请读者在熟悉ReactiveCocoa2.5的基础上 继续阅读本文。
图片来源： www.jianshu.com/p/d7d951a99db8
实现原理
1. 利用RACBehaviorSubject每次被sub的时候都会把保存的最新值发送给订阅者。
2. RACBehaviorSubject继承于RACSubject，所以当它被sub时都会调用RACSubject 的subscribe方法，在RACSubject 的subscribe方法中，核心代码就是用一个数组把所有订阅者保存起来，在pub的时候遍历该数组，给所有的订阅者发消息。这样就实现了NSNotificationCenter的功能。
3. Talk is cheap, show me the code! (哈哈。。。)
RACBehaviorSubject源码分析
RACSubject源码分析
自定义类RACEventHandler
RACEventHandler.h
RACEventHandler.m
请读者在熟悉ReactiveCocoa2.5的基础上 继续阅读本文。 图片来源： www.jianshu.com/...
实现方式 通过数据结构list来实现 通过pub/sub实现 通过List实现 实现机制 优点 能够实现持久化：可...
利用fanout类型exchange实现pub-sub模式，广播者发送，所有接受者接收声明exchange时候配置...
概述 Redis实现消息队列有两种形式： 广播订阅模式：基于Redis的 Pub/Sub 机制，一旦有客户端往某个...
先介绍一下redis的pub/sub功能： Pub/Sub功能（means Publish, Subscribe）...
1. PUB & SUB模式 pub & sub模式的核心在于: subscriber向publisher注册fi...
1.什么是pub/sub Pub/Sub功能（means Publish, Subscribe）即发布及订阅功能。...
本篇主要介绍PUB/SUB模式 PUB/SUB模式区别于P2P模式，PUB/SUB模式下一个消息可以被多个消费者消...
1. 什么是发布订阅机制 （PUB/SUB） 除了普通的数据类型之外，Redis其实还支持一种类似消息推送的机制，...
发布与订阅 P52 Redis 实现了发布与订阅（publish/subscribe）模式，又称 pub/sub ...
本文标题：利用RACBehaviorSubject实现pub/sub机制，
本文链接：https://www.haomeiwen.com/subject/lkaizttx.html
网友评论
_accountInfoSubscription = [[RACEventHandler subscribe:[AccountInfo class]] subscribeNext:^(AccountInfo *accountInfo) {
@strongify(self);
// TODO: 业务处理
}];
- (RACSignal *)queryMyAccount {
return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[[_userService queryMyAccount] subscribeNext:^(AccountInfo *accountInfo) {
[RACEventHandler publish:accountInfo];
[subscriber sendCompleted];
} error:^(NSError *error) {
[subscriber sendError:error];
}];
return nil;
}];
}