处理 Observable.subscribe 的结果时未调用 OnNext答案

【问题标题】：OnNext not called when disposing the result of Observable.subscribe处理 Observable.subscribe 的结果时未调用 OnNext
【发布时间】：2017-09-12 14:28:31
【问题描述】：

我订阅了一个 observable，但如果我将一次性添加到我班级的 DisposeBag 中，则永远不会调用 onNext 块。

这是我的代码：

@objc class AppleMusicPlaylistManager: NSObject {

    let disposeBag = DisposeBag()
    let playlists: [MPMediaPlaylist] = []

    func importAppleMusicPlaylist() {
        playlists.forEach { applePlaylist in
            applePlaylist.getItunesStoreTracks().subscribe(onNext: { tracks in
               // Doing things here
            }).addDisposableTo(disposeBag)
        }
    }
}

其中getItunesStoreTracks 返回一个RxSwift.Observable<[SoundsMusicITunesStore]>，整个事情就像AppleMusicPlaylistManager().importAppleMusicPlaylist() 一样使用

【问题讨论】：

因为你的 subscribe 返回一个 disposable 只是将它分配给某个变量，然后当你的对象得到 deinit 时处理它
@Lamar 根据我对 RxSwift 的理解，这正是 DisposeBag 正在做的事情。我在这里错过了什么吗？

标签： swift rx-swift

【解决方案1】：

一切都按预期工作。

disposeBag 的当前逻辑指出，在disposeBag 存活之前，不会处理可观察对象。

在您的情况下 - AppleMusicPlaylistManager().importAppleMusicPlaylist()，您创建了一个管理器，然后调用异步请求，而管理器正在解除分配。因此所有的 observables 也在释放。

为了使其正常工作，您必须将此管理器设置为 shared 并使用此方法：AppleMusicPlaylistManager.shared.importAppleMusicPlaylist() 或将此管理器保存到某个属性，以免立即解除分配。

【讨论】：