冷信号和热信号构建触发流程

十一月 27, 2020 发布在 ios

提到RAC就离不开冷热信号。在实际的开发中如果不理清两者的用法就会出问题。

冷信号像专车，从你打车（订阅）开始，从出发地点（sendNext）发往你在的地方。它是一对一的，不会错过。

热信号像公交车，在你等车（订阅）之前可能已经发车了（sendNext）；不仅你可以上，其他人也能上，它是一对多的；错过了这班车（假设只有一班）就没了。

阅读全文

上一页
第 2 页共 2 页

董二千

愿你走出半生归来仍是少年

iOS Developer

China

iOS中的方法编码

Jun 6, 2021

当我们在日常开发中，如果涉及到一些iOS底层的东西就可能会遇到方法编码，这是了解这门语言必不可少的一个环节。

Weak的实现-&SideTables()[oldObj]

Dec 12, 2020

&SideTables()[oldObj]这是什么？很多人看到这里都被这操作搞蒙了，下面分三步来理解，分别是SideTables()、[oldObj]、&。先贴上入口的代码

id oldObj;
SideTable *oldTable;

oldObj = *location;
oldTable = &SideTables()[oldObj];

Weak的实现（一）

Dec 12, 2020

本文较长分三篇按序阅读体验更佳，第四篇为辅助阅读按需看

带着问题看源码：

大家都知道weak的底层实现是一个散列表，那么散列表的结构是什么样的？
散列表的key是什么，value是什么，散列函数是怎样的？
通过几次查找才能找到对应的弱引用？
如何查找弱引用对象的引用计数？
一个对象对应一个SideTable表而一个SideTable对应多个对象，为什么这样设计

Weak的实现（三）

Dec 12, 2020

本文较长分三篇按序阅读体验更佳，第四篇为辅助阅读按需看

正文接 Weak的实现（二）

3 设置弱引用标志位

Weak的实现（二）

Dec 12, 2020

正文接 Weak的实现（一）

2 生成新的`weak_entry_t`插入到`weak_entries`中

CombineLatest、Zip和Merge的区别

Nov 11, 2020

信号触发方式

merge

只要merge之后生成的信号被订阅就会自动触发所有压缩信号的订阅回调，如果靠前的信号出现了error后面的信号不再发送。

核心方法：- (instancetype)flatten
值：多次收到，分开的

 1
 2

RACSignal *s1 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
  [subscriber sendNext:@"1"];
    return nil;
}];

RACSignal *s2 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
    [subscriber sendNext:@"2"];
    return nil;
}];

[[RACSignal merge:@[s1,s2]] subscribeNext:^(id x) {
    NSLog(@"%@",x);
}];

Connect、AutoConnect、RACReplaySubject、Replay

Nov 11, 2020

Connect

将冷信号包装成热信号，初始化冷信号，调用publish方法会自动生成一个RACMulticastConnection，该对象持有了原始信号和一个热信号。

- (RACMulticastConnection *)publish {
	RACSubject *subject = [[RACSubject subject] setNameWithFormat:@"[%@] -publish", self.name];
	RACMulticastConnection *connection = [self multicast:subject];
	return connection;
}
- (RACMulticastConnection *)multicast:(RACSubject *)subject {
	[subject setNameWithFormat:@"[%@] -multicast: %@", self.name, subject.name];
	RACMulticastConnection *connection = [[RACMulticastConnection alloc] initWithSourceSignal:self subject:subject];
	return connection;
}

调用connect方法来触发订阅，注意调用一次触发一次。

RACSignal

Nov 11, 2020

创建信号


RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@"1"];
        return nil;
    }];

分析

//RACSignal.m
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
	return [RACDynamicSignal createSignal:didSubscribe];
}

SwitchToLatest

Nov 11, 2020

- (RACSignal *)switchToLatest和- (RACSignal *)flatten的功能类似，都可以将信号中的信号的值取出来。不同的是，前者如果订阅者处理多个信号，只有最后一个信号的值能收到，之前的信号会被销毁。而后者则都能收到所有值。

concat、catchTo、never、takeUntil

Nov 11, 2020

- (RACSignal *)concat:(RACSignal *)signal

//源码
- (RACSignal *)concat:(RACSignal *)signal {
	return [[RACSignal createSignal:^(id<RACSubscriber> subscriber) {
		RACSerialDisposable *serialDisposable = [[RACSerialDisposable alloc] init];

		RACDisposable *sourceDisposable = [self subscribeNext:^(id x) {
			[subscriber sendNext:x];
		} error:^(NSError *error) {
			[subscriber sendError:error];
		} completed:^{
			RACDisposable *concattedDisposable = [signal subscribe:subscriber];
			serialDisposable.disposable = concattedDisposable;
		}];

		serialDisposable.disposable = sourceDisposable;
		return serialDisposable;
	}] setNameWithFormat:@"[%@] -concat: %@", self.name, signal];
}

冷信号和热信号构建触发流程

董二千

iOS中的方法编码

Weak的实现-&SideTables()[oldObj]

Weak的实现（一）

Weak的实现（三）

正文 接 Weak的实现（二）

3 设置弱引用标志位

Weak的实现（二）

正文 接 Weak的实现（一）

2 生成新的weak_entry_t插入到weak_entries中

CombineLatest、Zip和Merge的区别

信号触发方式

merge

Connect、AutoConnect、RACReplaySubject、Replay

Connect

RACSignal

创建信号

SwitchToLatest

concat、catchTo、never、takeUntil

正文接 Weak的实现（二）

正文接 Weak的实现（一）

2 生成新的`weak_entry_t`插入到`weak_entries`中