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

概述我如何实现一个RACSignal,它会在没有订阅者的情况下停止发布,并在有订阅者时自动启动？ 这是一个场景： 我们假设我在AppDelegate中有一个currentLocationSignal. 我的LocationViewController将在视图加载时订阅currentLocationSignal,并在视图卸载时取消订阅(dispose).由于获取当前位置需要几秒钟,我想在应用程序打开时始 我如何实现一个RACSignal,它会在没有订阅者的情况下停止发布,并在有订阅者时自动启动？

这是一个场景：

我们假设我在AppDelegate中有一个currentLocationSignal.
我的LocationVIEwController将在视图加载时订阅currentLocationSignal,并在视图卸载时取消订阅(dispose).由于获取当前位置需要几秒钟,我想在应用程序打开时始终订阅currentLocationSignal(并在几秒后自动取消订阅),所以当我到达LocationVIEwController时,我会得到一个准确的位置.
因此,信号可能有多个订户.当第一个订阅者侦听时,它需要开始调用startUpdatingLocation,当没有订阅者时,它需要调用stopUpdatingLocation.

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

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

我们首先添加一个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：block.发生这种情况时：

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

现在,剩下的就是在启动时订阅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：signal发送其第一个值时自动处理该订阅.

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

总结

以上是内存溢出为你收集整理的ios – 在没有订阅者时停止发布,在有订阅者时自动启动全部内容，希望文章能够帮你解决ios – 在没有订阅者时停止发布,在有订阅者时自动启动所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。