RxSwift For Dummies 🐣 Part3

好了, 接下来是第三个部分。Subjects

学了之前内容. 我们可能已经发现了。之前学习的内容都是 Observables 输出事件的部分。我们可以订阅他, 就能知道他输出的事件了。但是我们还不能改变他。

Subject 也是一个 Observable 但是他是能够同时输入和输出的。也就是说, 我们可以动态(强制)的在一个序列中发出信号。

let subject = PublishSubject<String>()
// 可以直接转换，因为他也是一个 `Observable`
let observable: Observable<String> = subject
observable.subscribe(onNext: { (text) in
    print(text)
}).addDisposableTo(disposeBag)
// 只要你想发出一个新的事件, 就可以用 onNext 方法 
subject.onNext("Hey!")
subject.onNext("I'm back!")

onNext 是一个输出事件的方法。最后控制台会输出

“Hey!”
“I’m back!”

Subject 到底有什么用呢? 为了很轻松的将 Rxswift 中声明式的世界和我们平常的世界连接起来。让我们在需要写实现式的代码的时候更 Rx

在一个纯正的 Rx 的世界里。当你需要有一个更完美的流的时候, 不用去管这个 Observable 是怎么实现的。这个东西我会另外的解释。反正, 如果你需要，大胆的用吧。

上面式关于 Subject 最基本的内容。接下来我们学习一下怎么更好的使用 Subject

Hot🔥 vs Cold❄️

在第一篇文章中就已经提到过了热信号🔥和冷信号❄️。今天我们在深入的了解一点吧，因为 Subject 实际上是我们第一次接触到真正的热信号。

我们一定确定了，当我们使用 create 创建一个 Observable 的时候, 由于没有人订阅他，所以她是不会发送消息的。只有被 subscribe(订阅)之后才会开始发送消息出来。这就是我们叫它为冷信号❄️的原因。如果很不幸你忘了这个知识点。你可以回到第一篇文章去看看。热信号🔥 就是那种即使没有被订阅也会发出消息的信号, 这也是 subject 做的事情。

let subject = PublishSubject<String>()
let observable: Observable<String> = subject
// 这个信号还没有被订阅, 所以这个值不回被接受到
subject.onNext("Am I too early for the party?")
observable
    .subscribe(onNext: { (text) in
        print(text)
    }).addDisposableTo(disposeBag)
// 这个值发出来的时候已经有一个订阅者了, 所以这个值会打印出来
subject.onNext("🎉🎉🎉")

很简单直接吧。如果在第一篇中你理解了冷信号的话, 理解热信号也是很自然的事情。

Subject Types

常用的 Subject 有三种。他们其实都差不多, 唯一的区别就是: 在订阅之前, 它会干什么。

Publish Subject

在上面的例子中已经说到了。 PublishSubject 会忽略掉在订阅之前发出来的信号。

let subject = PublishSubject<String>()
let observable: Observable<String> = subject
subject.onNext("Ignored...")
observable.subscribe(onNext: { (text) in
    print(text)
}).addDisposableTo(disposeBag)
subject.onNext("Printed!")

当你只关注你订阅之后发生了什么的时候, 就可以使用 PublishSubject

Replay Subjects

ReplaySubject 会将最后 n 个值发出来, 即使是订阅发生之前的值。这个 n 个值被被放在一个环从区里面。在这个例子中会缓有 3 个值被保留。

let subject = ReplaySubject<String>.create(bufferSize: 3)
let observable: Observable<String> = subject
subject.onNext("Not printed!")
subject.onNext("Printed")
subject.onNext("Printed!")
subject.onNext("Printed!")
observable.subscribe(onNext: { (text) in
    print(text)
}).addDisposableTo(disposeBag)
subject .onNext("Printed!")

当我们需要知道订阅之前发生了什么的时候, 我们就需要使用 ReplaySubject 了。

Behavior Subject

BehaviorSubject 只会重复最后一个值。更其他的 Subject 的同，他在创建的时候就需要给定一个初始值。

let subject = BehaviorSubject<String>(value: "Initial value")
let observable: Observable<String> = subject
subject.onNext("Not printed!")
subject.onNext("Not printed!")
subject.onNext("Printed!")
observable.subscribe(onNext: { (text) in
    print(text)
}).addDisposableTo(disposeBag)
subject.onNext("Printed!")

当你只需要知道最后一个值的时候。就需要使用 BehaviorSubject

Binding

你可以把一个 Observable 和 Subject 绑定到一起。也就是说可以让这个 Observable 将它的序列里的所有值都发送给这个 Subject

let subject = PublishSubject<String>()
let observable = Observable<String>.just("I'm being passed around 😲")
subject.subscribe(onNext: { (text) in
    print(text)
}).addDisposableTo(disposeBag)
observable.subscribe { (event) in
    subject.on(event)
}.addDisposableTo(disposeBag)

有一个语法糖来简化这些代码。

let subject = PublishSubject<String>()
let observable = Observable<String>.just("I'm being passed around 😲")
subject.subscribe(onNext: { (text) in
    print(text)
}).addDisposableTo(disposeBag)
observable.bind(to: subject).addDisposableTo(disposeBag)

输出

I’m being passed around 😲

Warning

Binding 不仅仅会传递值, 他也会把完成和错误都传递过来。这种情况下这个 Subject 就会被释放。

Quick Example

还是把第一篇文章中的 Demo 稍微修改一下吧。

import Foundation
import RxCocoa
import RxSwift
final class GoogleModel {
    let googleString = BehaviorSubject<String>(value: "")
    private let disposeBag = DisposeBag()
    
    
    func fetchNetString()  {
        let observable = Observable<String>.create { (observer) -> Disposable in
            let session = URLSession.shared
            let task = session.dataTask(with: URL(string: "https://www.google.com")!, completionHandler: { (data, response, error) in
                
                DispatchQueue.main.async {
                    if let err = error {
                        observer.onError(err)
                    } else {
                        let googleString = NSString(data: data!, encoding: 1) as String?
                        
                        observer.onNext(googleString!)
                        observer.onCompleted()
                    }
                }
            })
            task.resume()
            return Disposables.create{
                task.cancel()
            }
        }
        
        // Bind the observable to the subject
        observable.bind(to: googleString).addDisposableTo(disposeBag)
    }
}        
// Bind the observable to the subject
observable.bind(to: googleString).addDisposableTo(disposeBag)

可以看到，在这个例子中，我们有一个视图模型将 googleString 这个 subject 暴露出来。让 ViewController 能够订阅。我们将这个 observable 绑定到这个 subject 上, 这样我们就可以在网络请求有结果的时候, 立马将请求结果传递到这给 subject。

Bonus: Variable

距离完完全全的 Rx 还差最后一点了。强行的获取之前发送出来的值。

这就是为什么会有 Variable 这个东西了。Variable 是对 BehaviorSubject 的简单包装。可以看一下它的实现是非常简单的。但它却非常的方便。

还是用一个小例子来说明这个问题吧。在这个例子中, 我们需要在任何时间都可以得到 “googleString” “当前” 的值。

let googleString = Variable("currentString")
// get
print(googleString.value)
// set
googleString.value = "newString"
// 订阅
googleString.asObservable().subscribe(onNext: { (text) in
    print(text)
}).addDisposableTo(disposeBag)