swift - 如何防止可观察量被终止

Question

let loadNextPageTrigger = PublishSubject<Void>()

let loading = Variable<Bool>(false)


let nextPageRequest = loading.asObservable()

    .sample(loadNextPageTrigger)

    .flatMap { [unowned self] loading -> Observable<Int> in

        if (loading || self.pageStatus != true || self.netStatus != true) {

            return Observable.empty()

        }
        else
        {

            return Observable<Int>.create
                { [unowned self] observer in

                    print("self.pageIndex called",self.offset)

                    self.offset += 20

                    observer.onNext(self.offset)

                    observer.onCompleted()

                    return Disposables.create()

            }

        }

}

返回 obervable.empty() 时，它会终止 Observable。

Answer 1

您需要使用单例来管理您的代码。这将保持可观察性，并将在整个应用程序中存在。从单例类中使用