我創建基於CocoaAsyncSocket和STOMP協議的簡單消息應用程序。因此，我創建主類，它使用PublishSubject，所以用戶可以觀察傳入STOMP幀，這樣的事情： class StompStream: NSObject {
//MARK: - Public
var inputFrame = PublishSubject<StompFrame>()
//MARK: -
我試圖開始使用RxSwift，因此我嘗試創建一個請求的函數，並試圖實現與TRON（我使用的HTTP庫）一起提供的rxResult（）函數。但關於這方面的文檔不是很詳細。任何人都可以在正確的方向上指出我做錯了什麼？這是我寫的函數： static func readAllWithRx() {
let token = UserDefaults.standard.value(forKey: Co
我有一個使用第三方庫的例子，我想將它變成一個Observable。恰當地說，圖書館是圍繞代表設計的，正如人們期望的那樣，我正在包裝它。庫執行異步操作，並在完成時調用它的代理和結果。 我絕對想利用可觀察性的cold性質，只有在有人訂閱時纔開始操作。我有一個可行的解決方案，我只是不知道它是否存在嚴重缺陷，我錯過了對RxSwift的一些重要理解，或者可能有更簡單的方法來實現相同的目標。 public f