在 RxSwift PublishSubject 上完成后订阅最后一个值

Question

我正在寻找这样的东西：

let observable = PublishSubject<String>()
observable.onNext("1")
observable.onCompleted()

_ = observable.subscribeNext { s in
    print(s)
}

所以我想在 Observable 完成后订阅它并仍然获取值（或只是最后一个值）。

Answer 1

您使用错误的 Subject 来获得您想要的。 Take a look at the descriptions of the Subjects:

PublishSubject：在订阅时向所有观察者广播新事件。

ReplaySubject：向所有订阅者广播新事件，向新订阅者广播指定bufferSize数量的先前事件。

BehaviorSubject：向所有订阅者广播新事件，向新订阅者广播最新（或初始）值。

Variable：包装一个 BehaviorSubject，因此它将向新订阅者发出最新（或初始）值。并且 Variable 也保持当前值状态。变量永远不会发出错误事件。但是，它会自动发出一个 Completed 事件并在 deinit 时终止。

所以，不要使用 PublishSubject，因为它只会在订阅后广播 新事件。

您可以使用 ReplaySubject 获取所有以前的事件，或者您可以使用 ReplaySubject、BehaviorSubject 或 Variable 获取最近的值。

let disposeBag = DisposeBag()

// ALL previous events
let subject = ReplaySubject<String>.createUnbounded()
// or use this to get just the last, say, 4:
//   let subject = ReplaySubject<String>.create(bufferSize: 4)
// or use one of these to get the most recent:
//   let subject = ReplaySubject<String>.create(bufferSize: 1)
//   let subject = BehaviorSubject(value: "blah")
//   let subject = Variable("blah")

subject.onNext("blah")
subject.onNext("foo")
subject.onCompleted()

subject
    .asObservable()
    .subscribeNext { print([=10=]) }
    .addDisposableTo(disposeBag)

输出：

blah
foo

在 RxSwift PublishSubject 上完成后订阅最后一个值

Subscribe to last value after completed on RxSwift PublishSubject

swift

rx-swift

reactivex