如何在RXSwift中间接观察单个？

Question

因此，我有了这个存储库层，它返回一个single

func getNearby(origin: String, page: Int)-> Single<[MyObject]>

在我的ViewModel中，我有以下代码

private let _nearbyObservable: PublishSubject<[MyObject]> = PublishSubject()
var nearbyObservable: Single<[MyObject]> {return _nearbyObservable.asSingle()}

func loadNearby(origin: String, page: Int) {
        searchRepository
            .getNearby(origin: origin, page: page)
            .observe(on: scheduler)
            .subscribe(with: _nearbyObservable)
            .disposed(by: disposeBag)
    }

在我的ViewController中，我有

viewModel.loadNearby()
viewModel.nearbyObservable.subscribe(
            onSuccess: { objects in
                print(objects.count)
                print("Got a value: \(hitches)")
            },
            onFailure: { error in
                print("Something went wrong: \(error)")
            }
        ).disposed(by: disposeBag)

这不起作用。任何帮助都是非常感激的。

Answer 1

如果您希望VC订阅一次，那么将VMnearbyobservable的输出设置为single是没有意义的，所以您应该将其更改为observable。通过使用.subscribe(with:_NearbyObservable)，您实际上是在转发发出的所有事件（包括将处置订阅的已完成事件），因此如果您想要维护当前的实现，您可以执行以下操作：（此代码可能可以工作，但不应该执行此操作）

private let _nearbyObservable: PublishSubject<[MyObject]> = PublishSubject()
var nearbyObservable: Observable<[MyObject]> {return _nearbyObservable }

func loadNearby(origin: String, page: Int) {
    searchRepository
        .getNearby(origin: origin, page: page)
        .observe(on: scheduler) // Not sure if this needs to be changed
        .subscribe(onSuccess: _nearbyObservable.onNext)
        .disposed(by: disposeBag)
}

和VC端：

viewModel.nearbyObservable.subscribe(
    onNext: { objects in
        print(objects.count)
        print("Got a value: \(hitches)")
    },
    onError: { error in
        print("Something went wrong: \(error)")
    }
).disposed(by: disposeBag)
viewModel.loadNearby()