我正在RxSwift中使用重試運算符。根據其文檔，當遇到錯誤時，它將“重新訂閱”可觀察到的源。 這一切都很好。但是，我不確定在包含熱觀測值或熱/冷觀測值混合的“源可觀測”時如何推理。 我敢肯定一個例子： 讓coldObservable = Observable.interval（.seconds（1），調度程序：MainScheduler.instance） let coldObservableRetry = coldObservable.flatMapLatest {num in 如果num％3 == 0 {return .just（num）} 否則{return .error（）} } .retry（2）//重試包含原始嘗試 coldObservableRetry.subscribe（onNext：{print（$ 0）}）//在出現錯誤之前打印1，2，1，2,。 我不確定的一個例子： let hotObservable = Observable .interval（.seconds（1），調度程序：MainScheduler.instance）.publish（）。connect（） let hotObservableRetry = hotObservable.flatMapLatest {num in 如果num％3 == 0 {return .just（num）} 否則{return .error（）} } .retry（2） hotObservableRetry.subscribe（onNext：{print（$ 0）}）//這裡發生了什麼？ 我不確定的另一個示例： 讓coldObservable = Observable .interval（.seconds（1），調度程序：MainScheduler.instance） 讓delayHotObservable = Observable .interval（.seconds（1），調度程序：MainScheduler.instance）.delay（.milliseconds（100），調度程序：MainScheduler.instance）.publish（）。connect（） let blendObservableRetry = Observable.combineLatest（coldObservable，delayHotObservable）.map {$ 0 + $ 1} .flatMapLatest {num in 如果num％3 == 0 {return .just（num）} 否則{return .error（）} } .retry（5） blendObservableRetry.subscribe（onNext：{print（$ 0）}）//這裡發生了什麼？重新訂閱帶有可觀察到的熱和冷現象的CombineLatest甚至意味著什麼？ 我不確定的另一個例子： 讓coldObservable = Observable .interval（.seconds（1），調度程序：MainScheduler.instance） let hotObservable = Observable .interval（.seconds（1），調度程序：MainScheduler.instance）.publish（）。connect（） let blendObservable2Retry = coldObservable.flatMapLatest {_在hotObservable} .flatMapLatest { 如果num％3 == 0 {return .just（num）} 否則{return .error（）} } .retry（2） blendObservable2Retry.subscribe（onNext：{print（$ 0）}）//這裡發生了什麼？
2021-02-26 08:15:54
您的許多示例都無法編譯，因此會發生編譯錯誤。 :-)但要回答所問的問題...
有一些重要的事情要牢記。
每個操作員都訂閱其源可觀察對象並生成一個新的可觀察對象。
訂閱了冷的可觀察對象時，它將發出0 ... N個下一個事件，然後發出一個stop事件（已完成或錯誤）。它將為每個訂閱提供自己的事件集。
熱的可觀察對象直到它們的連接被調用後才開始發射。所有訂閱將共享同一組事件。
最後，在這種情況下，debug是您的朋友。
因此，對於您的第一個示例，您不確定（經過調整後將其編譯並運行，並添加了一些調試運算符）：
func example（）{
let hotObservable = Observable .interval（.seconds（1），調度程序：MainScheduler.instance）
.debug（“發布前”）
。發布（）
讓hotObservableRetry = hotObservable
.debug（“發布後”）
.map {（num）-> Int in
警衛號％3！= 0否則{throw MyError（）}
返回數字
}
.debug（“之後的地圖”）
.retry（2）
.debug（“重試後”）
_ = hotObservableRetry.subscribe（）
_ = hotObservable.connect（）
}
將產生以下輸出。
這裡有一些關於輸出的注意事項，將有助於學習過程。
訂閱以相反的順序發生。
發出第一個錯誤後，重試運算符將重新訂閱地圖運算符的observable，而後者將重新訂閱發布的observable。由於發布的可觀察性很熱門，因此重新訂閱鏈就此停止。計時器的可觀察項不會被重新訂閱。
以上是理解該問題的要點。
重試後->已訂閱
地圖後->已訂閱
發布後->訂閱
發布之前->已訂閱
發布前->事件下一個（0）
發布後->事件next（0）
映射後->事件錯誤（MyError（））
地圖後-> isDisposed
發布後-> isDisposed
地圖後->已訂閱
發布後->訂閱
發布前->事件next（1）
發布後->事件next（1）
地圖後->事件下一個（1）
重試後->事件next（1）
發布前->事件next（2）
發布後->事件next（2）
地圖後->事件下一個（2）
重試後->事件next（2）
發布前->事件next（3）
發布後->事件next（3）
映射後->事件錯誤（MyError（））
重試後->事件錯誤（MyError（））
重試後-> isDisposed
地圖後-> isDisposed
發布後-> isDisposed
發布前->事件next（4）
發布前->事件下一個（5）
發布前->事件下一個（6）
...
在您顯示的下一個示例中，CombineLatest運算符重新訂閱了熱的可觀察對象，但是可連接的可觀察對像沒有重新訂閱其源。
7
|
你的答案
StackExchange.ifUsing（“ editor”，function（）{
StackExchange.using（“ externalEditor”，function（）{
StackExchange.using（“ snippets”，function（）{
StackExchange.snippets.init（）;
}）;
}）;
}，“代碼段”）；
StackExchange.ready（function（）{
var channelOptions = {
標籤：“” .split（“”），
id：“ 1”
};
initTagRenderer（“”。split（“”），“” .split（“”），channelOptions）;
StackExchange.using（“ externalEditor”，function（）{
//如果啟用了摘要，則必須在摘要後觸發編輯器
如果（StackExchange.settings.snippets.snippetsEnabled）{
StackExchange.using（“ snippets”，function（）{
createEditor（）;
}）;
}
別的 {
createEditor（）;
}
}）;
函數createEditor（）{
StackExchange.prepareEditor（{
useStacksEditor：否，
heartbeatType：“答案”，
autoActivateHeartbeat：否，
convertImagesToLinks：是，
noModals：是的，
showLowRepImageUploadWarning：是的，
聲望：ToPostImages：10，
bindNavPrevention：是的，
後綴：“”，
imageUploader：{
brandingHtml：“採用\ u003ca href = \“ https：//imgur.com/ \” \ u003e \ u003csvg class = \“ svg-icon \” width = \“ 50 \” height = \“ 18 \” viewBox = \“ 0 0 50 18 \” fill = \“ none \” xmlns = \“ http：//www.w3.org/2000/svg \” \ u003e \ u003cpath d = \“ M46.1709 9.17788C46.1709 8.26454 46.2665 7.94324 47.1084 7.58816C47.4091 7.46349 47.7169 7.36433 48.0099 7.26993C48.9099 6.97997 49.672 6.73443 49.672 5.93063C49.672 5.22043 48.9832 4.61182 48.1414 4.61182C47.4335 4.61182 46.7256 4.91628 46.0943 5.50789C45.74.6 4.313.6412 4.313.6662 43.1481 6.59048V11.9512C43.1481 13.2535 43.6264 13.8962 44.6595 13.8962C45.6924 13.8962 46.1709 13.2535 46.1709 11.9512V9.17788Z \“ / \ u003e \ u003cpath d = \” M32.492 10.1419C32.492 12.6954 34.1182 14.048437.0451 14.0484 41.5985 12.6954 41.5985 10.1419V6.59049C41.5985 5.28821 41.1394 4.66232 40.1061 4.66232C39.0732 4.66232 38.5948 5.28821 38.5948 6.59049V9.60062C38.5948 10.8521 38.2696 11.5455 37.0451 11.5455C35.8209 11.5455 35.4954 10.8 521 35.4954 9.60062V6.59049C35.4954 5.28821 35.0173 4.66232 34.0034 4.66232C32.9703 4.66232 32.492 5.28821 32.492 6.59049V10.1419Z \“ / \ u003e \ u003cpath fill-rule = \” evenodd \“ clip-rule = \” evenodd \“ d = \“ M25.6622 17.6335C27.8049 17.6335 29.3739 16.9402 30.2537 15.6379C30.8468 14.7755 30.9615 13.5579 30.961511.9512V6.59049C30.9615 5.28821 30.4833 4.66231 29.4502 4.66231C28.9913 4.66231 28.4555 4.94978 28.1109 5.50789C27.499 4.86533 26.7335 4.56087 25.7005 4.56087C23.1369 4.56087 21.0134 6.57349 21.0134 9.27932C21.0134 11.9852 13.003 13.913 25.3607 12.6616C28.1109 12.7229 28.1161 12.7799 28.121 12.8346C28.1256 12.8854 28.1301 12.9342 28.1301 12.983C28.1301 14.4373 27.2502 15.2321 25.777 15.2321C24.8349 15.2321 24.1352 14.9821 23.5661 14.7787C23.176 14.6393 22.452 12.5218 21.2429429 14.65218 21.2429429 .2429 16.7375 22.9072 17.6335 25.6622 17.6335ZM24.1317 9.27932C24.1317 7.94324 24.9928 7.09766 26.1024 7.09766C27.2119 7.09766 28.0918 7.94324 28.0918 9.27932C28.0918 10.6321 27.2311 11.5116 26.1024 11.5116C24.9737 11.5116 24.1317 10.279 u003cpath d = \“ M16.8045 11.9512C16.8045 13.2535 17.2637 13.8962 18.2965 13.8962C19.3298 13.8962 19.8079 13.2535 19.8079 11.9512V8.12928C19.8079 5.82936 18.4879 4.62866 16.4027 4.62866C15.1594 4.62866 14.279 4.98375 13.3609 5.88013C12.653 5.05154 11.6581 4.62866 10.3573 4.62866C9.34336 4.62866 8.57809 4.89931 7.9466 5.5079C7.58314 4.9328 7.10506 4.66232 6.51203 4.66232C5.47873 4.662325.00066 5.47873 13.8962 6.51203 13.8962C7.54479 13.8962 8.0232 13.2535 8.0232 11.9512V8.90741C8.0232 7.58817 8.44431 6.91179 9.53458 6.91179C10.5104 6.91179 10.893 7.58817 10.893 8.94108V11.9512C10.893 13.2535 11.3711 13.8962 12.4044 13.8962C13.4375.13 90741C13.9157 7.58817 14.3365 6.91179 15.4269 6.91179C16.4027 6.91179 16.8045 7.58817 16.8045 8.94108V11.9512Z \“ / \ u003e \ u003cpath d = \” M3.31675 6.59049C3.31675 5.28821 2.83866 4.66232 1.82471 4.66232C0.7917288 4.21 0.313 V11.9512C0.313354 13.2535 0.791758 13.8962 1.82471 13.8962C2.85798 13.8962 3.31675 13.2535 3.31675 11.9512V6.59049Z \“ / \ u003e \ u003cpath d = \” M1.87209 0.400291C0.843612 0.400291 0 1.1159 0 1.98861C0 2.87869 0.822846 3.57676 1.87209 3.57676C2.90056 3.57676 3.7234 2.87869 3.7234 1.98861C3.7234 1.1159 2.90056 0.400291 1.87209 0.400291Z \“ fill = \”＃1BB76E \“ / \ u003e \ u003c / svg \ u003e \ u003c / a \ u003e”，
contentPolicyHtml：“根據\ u003ca href = \“ https：//stackoverflow.com/help/licensing \” \ u003ecc by-sa \ u003c / a \ u003e \ u003ca href = \“ https://stackoverflow.com獲得許可的用戶貢獻/ legal / content-policy \“ \ u003e（內容策略）\ u003c / a \ u003e”，
allowUrls：是
}，
onDemand：是的，
dispatchSelector：“。discard-answer”
，立即顯示MarkdownHelp：true，enableTables：true，enableSnippets：true
}）;
}
}）;
感謝您為Stack Overflow提供答案！
請務必回答問題。提供詳細信息並分享您的研究！
但是要避免...
尋求幫助，澄清或回答其他答案。
根據意見發表聲明；用參考或個人經驗來備份它們。
要了解更多信息，請參閱有關編寫出色答案的提示。
草稿已保存
草稿丟棄
註冊或登錄
StackExchange.ready（function（）{
StackExchange.helpers.onClickDraftSave（'＃login-link'）;
}）;
使用Google註冊
使用Facebook註冊
使用電子郵件和密碼註冊
提交
以訪客身份發布
姓名
電子郵件
必需，但從未顯示
StackExchange.ready（
功能 （） {
StackExchange.openid.initPostLogin（'。new-post-login'，'https％3a％2f％2fstackoverflow.com％2fquestions％2f64950463％2fhow-do-rxswift-operators-affect-resubscribes％23new-answer'，'question_page' ）;
}
）;
以訪客身份發布
姓名
電子郵件
必需，但從未顯示
發表您的答案
丟棄
點擊“發布答案”，即表示您同意我們的服務條款，隱私權政策和Cookie政策
不是您要找的答案？瀏覽標記為ios swift5 rx-swift的其他問題，或詢問您自己的問題。