没有订阅者时停止发布,有订阅者时自动启动

Question

如果RACSignal没有订阅者,我将如何实现停止发布？如果有订阅者则自动启动？

这是一个场景:

让我们说我有一个currentLocationSignal在AppDelegate.当视图卸载时,我LocationViewController会订阅currentLocationSignal视图加载和取消订阅(dispose).由于获取当前位置需要几秒钟,我希望始终订阅currentLocationSignal应用程序打开的时间(并在几秒钟后自动取消订阅),所以当我到达时,LocationViewController我会得到一个准确的位置.因此,信号可能有多个订户.当第一个用户收听时,它需要开始呼叫startUpdatingLocation,当没有用户需要呼叫时stopUpdatingLocation.

Answer 1

好问题!通常,您可以将RACMulticastConnection用于此类用例,但是,由于您希望信号能够在以后重新激活,因此连接本身并不合适.

最简单的答案可能是模仿连接的工作方式,但可以模拟您想要的特定行为.基本上,我们将跟踪在任何给定时间有多少订户,并根据该数字开始/停止更新位置.

让我们从添加locationSubject属性开始.主题需要是RACReplaySubject,因为我们总是希望新订阅者立即获取最近发送的位置.使用该主题实现更新很容易:

- (void)locationManager:(CLLocationManager *)manager didUpdateLocations:(NSArray *)locations {
    [self.locationSubject sendNext:locations.lastObject];
}

然后,我们希望实现跟踪和递增/递减订户计数的信号.这通过使用numberOfLocationSubscribers整数属性来工作:

- (RACSignal *)currentLocationSignal {
    return [RACSignal createSignal:^(id<RACSubscriber> subscriber) {
        @synchronized (self) {
            if (self.numberOfLocationSubscribers == 0) {
                [self.locationManager startUpdatingLocation];
            }

            ++self.numberOfLocationSubscribers;
        }

        [self.locationSubject subscribe:subscriber];

        return [RACDisposable disposableWithBlock:^{
            @synchronized (self) {
                --self.numberOfLocationSubscribers;
                if (self.numberOfLocationSubscribers == 0) {
                    [self.locationManager stopUpdatingLocation];
                }
            }
        }];
    }];
}

在上面的代码中,+createSignal:每次将新订户添加到返回的信号时都会调用该块.发生这种情况时:

1. 我们检查订户数目前是否为零.如果是这样,刚刚添加的订户是第一个,因此我们需要启用(或重新启用)位置更新.
2. 我们将订户直接挂到我们的locationSubject,因此后者的值会自动输入前者.
3. 然后,在将来某个时候,当处理订阅时,我们会减少计数并在适当时停止位置更新.

现在,剩下的就是订阅currentLocationSignal启动时,几秒后自动取消订阅:

- (BOOL)application:(UIApplication *)application didFinishLaunchingWithOptions:(NSDictionary *)launchOptions {
    // Use a capacity of 1 because we only ever care about the latest
    // location.
    self.locationSubject = [RACReplaySubject replaySubjectWithCapacity:1];

    [[self.currentLocationSignal
        takeUntil:[RACSignal interval:3]]
        subscribeCompleted:^{
            // We don't actually need to do anything here, but we need
            // a subscription to keep the location updating going for the
            // time specified.
        }];

    return YES;
}

这会self.currentLocationSignal立即订阅,然后在+interval:信号发送其第一个值时自动处理该订阅.

有趣的是,-[RACMulticastConnection autoconnect] 曾经表现得像-currentLocationSignal上面那样,但这种行为发生了变化,因为它使副作用变得非常难以预测.这个用例应该是安全的,但是当自动重新连接可怕时,还有其他时候(比如在发出网络请求或运行shell命令时).