RxSwiftのshare*の早見表
はじめに
RxSwiftの3.5.0からshare(replay:scope:)が追加されました。
3.5.0未満のshare()、shareReplay(_:)、shareReplayLatestWhileConnected()にどう対応しているのか書いていきます。
.share()
.share(scope: .forever)
.shareReplay(1)
.share(replay: 1, scope: .forever)
.shareReplayLatestWhileConnected()
.share(replay: 1, scope: .whileConnected)
参考
RxSwift/Observables/ShareReplayScope.swift
public func share(replay: Int = 0, scope: SubjectLifetimeScope)
-> Observable<E> {
switch scope {
case .forever:
switch replay {
case 0: return self.multicast(PublishSubject()).refCount()
default: return shareReplay(replay)
}
case .whileConnected:
switch replay {
case 0: return ShareWhileConnected(source: self.asObservable())
case 1: return ShareReplay1WhileConnected(source: self.asObservable())
default: return self.multicast(makeSubject: { ReplaySubject.create(bufferSize: replay) }).refCount()
}
}
}
追記
.share()
RxSwift/Observables/Multicast.swift
public func publish() -> ConnectableObservable<E> {
return self.multicast(PublishSubject())
}
public func share() -> Observable<E> {
return self.publish().refCount()
}
.shareReplayLatestWhileConnected()
RxSwift/Observables/ShareReplayScope.swift
public func shareReplayLatestWhileConnected() -> Observable<E> {
return ShareReplay1WhileConnected(source: self.asObservable())
}
RxSwift/Observables/Multicast.swift
public func publish() -> ConnectableObservable<E> {
return self.multicast(PublishSubject())
}
public func share() -> Observable<E> {
return self.publish().refCount()
}
RxSwift/Observables/ShareReplayScope.swift
public func shareReplayLatestWhileConnected() -> Observable<E> {
return ShareReplay1WhileConnected(source: self.asObservable())
}
Author And Source
この問題について(RxSwiftのshare*の早見表), 我々は、より多くの情報をここで見つけました https://qiita.com/marty-suzuki/items/593fa9550455364c052e著者帰属：元の著者の情報は、元のURLに含まれています。著作権は原作者に属する。
Content is automatically searched and collected through network algorithms . If there is a violation . Please contact us . We will adjust (correct author information ,or delete content ) as soon as possible .