RxSwift 正确使用变量

Question

我正在尝试将项目转换为使用 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

同步视图模型：

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

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

干杯！

Answer 1

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

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

在您的情况下，您已经有了冷可观察对象（网络调用），因此您不需要 Subject/Variable。您需要做的就是发布您已有的可观察对象并使用 replay(1) 来缓存该值。我希望一个名为 ParseServer 的 class 包含一个名为 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 { [=11=].map { Mushroom(pfObject: [=11=]) } }
        .publish()
        .replay(1)
    }
}

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

想法是，当您第一次调用 myParseServer.mushrooms 时，系统将调用 Parse 来取出蘑菇并缓存它们。以后就return之前兑现的蘑菇

RxSwift 正确使用变量

RxSwift Using Variables Correctly

architecture

mvvm

swift

rx-swift