RxSwift 正确使用变量

Posted 2023-02-22

【中文标题】RxSwift 正确使用变量

【英文标题】：RxSwift Using Variables Correctly

【发布时间】：2016-04-12 14:47:22

【问题描述】：

我正在尝试将项目转换为使用 RxSwift 和 MVVM。我有一项服务，可以在每次应用启动时同步 Parse 中的数据列表，我基本上想确保我采用了正确的方法。

我所做的是制作一个可变主题，然后让我的模型听这个。 解析服务：

let rx_parseMushrooms = Variable<[ParseMushroom]>([])

蘑菇图书馆模型：

_ = parseService.rx_parseMushrooms
    .asObservable()
    .map  (parseMushrooms:[ParseMushroom]) -> [Mushroom] in
        let mushrooms = parseMushrooms.map  (parseMushroom:ParseMushroom) -> Mushroom in
            let mushroom = Mapper<Mushroom>().map(parseMushroom.dictionaryWithValuesForKeys(parseMushroom.allKeys()))
            return mushroom!
        

        return mushrooms
    
    .subscribeNext( (mushrooms:[Mushroom]) -> Void in
        self.mushrooms = mushrooms
        print(mushrooms)
    )

我在表达同步状态时也是如此。

解析服务：

struct SyncState 
    enum State 
        case Unsynced, ConnectingToServer, SyncingInfo, FetchingImageList, SyncingImages, SyncComplete, SyncCompleteWithError
    

    var infoToSync = 0
    var imagesToSync = 0
    var imagesSynced = 0

    var state = State.Unsynced


let rx_syncState = Variable(SyncState())

然后我更新变量 a la

self.rx_syncState.value = self.syncState

SyncViewModel：

_ = parseService.rx_syncState
     .asObservable()
     .subscribeNext  [weak self] (syncState:ParseService.SyncState) -> Void in
          switch syncState.state 
              //show stuff based on state struct
          
      

无论如何，如果有人能告诉我这是否是一种好方法，或者我是否在滥用 RxSwift（并指导我应该如何做），我将不胜感激。

干杯！

【参考方案1】：

嗯...这是一篇关于使用变量的文章（请注意，变量是 BehaviorSubject 的包装器。）

http://davesexton.com/blog/post/To-Use-Subject-Or-Not-To-Use-Subject.aspx

在您的情况下，您已经有一个冷可观察对象（网络调用），因此您不需要主题/变量。您需要做的就是发布您已经拥有的 observable 并使用 replay(1) 来缓存该值。我希望有一个名为 ParseServer 的类，其中包含一个名为 mushrooms 的计算属性。

为了帮助让蘑菇脱离解析，您可以使用它（这将创建您需要的冷可观察对象）：

extension PFQuery 

    var rx_findObjects: Observable<[PFObject]> 
        return Observable.create  observer in
            self.findObjectsInBackgroundWithBlock( results, error in
                if let results = results 
                    observer.on(.Next(results))
                    observer.on(.Completed)
                
                else 
                    observer.on(.Error(error ?? RxError.Unknown))
                
            )
            return AnonymousDisposable( self.cancel() )
        
    

然后你会得到类似的东西：

class ParseServer 
    var mushrooms: Observable<[Mushroom]> 
        return PFQuery(className: "Mushroom").rx_findObjects
        .map  $0.map  Mushroom(pfObject: $0)  
        .publish()
        .replay(1)
    

我认为以上是正确的。我没有通过编译器运行它，更不用说测试它了。它可能需要编辑。

这个想法是，当你第一次调用myParseServer.mushrooms 时，系统会调用 Parse 来取出蘑菇并缓存它们。从此以后，它只会退回之前兑现的蘑菇。

【讨论】：

太棒了，感谢您的回复 :) 同步状态部分呢？基本上我有一个服务类，它会做很多事情，直到图书馆同步。这个“syncLibrary()”方法在应用程序启动时被调用，但我希望几个类能够监听同步状态，以防有新的蘑菇可用。我还有显示同步进度的初始屏幕。你也会让syncLibrary成为一个var吗？这是应用程序顺便说一句，以防它更好地解释我的工作 goo.gl/xJaV0d 它已经出来了我只是想掌握 RxSwift 它一直让我大吃一惊..

很酷的应用程序。就像我引用的文章说的那样，你很少需要主题（包括变量）。我认为它们主要在库中，因为当你有一些东西例如接受委托而不是回调并且你想将它转换成接收流。

在同步的情况下，您的数据库代码应该已经被包装，以便它返回 observables。有点像我上面为 PFObject 所做的。主题用于从无到有生成热门的可观察对象。您的数据库不应该生成热门的 observables。

是的。我想我仍然在围绕热与冷的可观察物进行研究。这是有道理的。再次感谢

简单的思考方式。当你订阅一个 hot observable 时，它​​所做的只是将观察者添加到它的观察者列表中。当您订阅冷可观察对象时，它会将观察者添加到列表中并开始某种过程。因此，例如 UIButton.rx_tap 很热，我上面代码中的 PFQuery.rx_findObjects 很冷（每次订阅都会调用一个新的服务器。）