我有一个包含整数值的信号 A。-1 值表示无效结果,所以我想发送错误,而不是将 -1 作为值传递。这样订阅 B 的任何东西都将通过 subscribeNext: 接收有效整数,并通过 subscribeError: 接收错误。
我想我知道如何用 RACSubject 做到这一点:
RACSequence *A = [@[ @(2), @(6), @(5), @(-1), @(4) ] rac_sequence];
RACSubject *B = [RACSubject subject];
[A subscribeNext:^(NSNumber *val) {
if ( [val integerValue] == -1 ) {
[B sendError:[NSError errorWithDomain:@"MyDomain" code:0 userInfo:nil]];
} else {
[B sendNext:val];
}
} error:^(NSError *error) {
[B sendError:error];
} completed:^{
[B sendCompleted];
}];
我想知道是否有一种更“内联”的方式来做到这一点:
RACSequence *A = [@[ @(2), @(6), @(5), @(-1), @(4) ] rac_sequence];
RACSignal *B = [A filter:^BOOL(id val) {
if ( [val integerValue] == -1 ) {
//FIXME: send an error to B's subscriber(s)
return NO;
} else {
return YES;
}
}