Skip to main content

RxSwift: Các loại Subject trong RxSwift

1. Khái niệm:

Subject trong RxSwift hoạt động như vừa là một Observable, vừa là một Observer. Khi một Subject nhận một .next event thì ngay lập tức nó sẽ phát ra các emit cho các subscriber của nó.

2. Khái quát:

Trong RxSwift, chúng ta có 4 loại Subject với các cách thức hoạt động khác nhau, bao gồm:
  • PublishSubject: Khởi đầu "empty" và chỉ emit các element mới cho subscriber của nó.
  • BehaviorSubject: Khởi đầu với một giá trí khởi tạo và sẽ relay lại element cuối cùng của chuỗi cho Subscriber mới.
  • ReplaySubject: Khởi tạo với một kích thước bộ đệm cố định, sau đó sẽ lưu trữ các element gần nhất vào bộ đệm này và relay lại các element chứa trong bộ đệm cho một Subscriber mới.
  • Variable: Lưu trữ một giá trị như một state và sẽ relay duy nhất giá trị cuối cùng cho Subscriber mới.

3. Chi tiết:

3.1. PublishSubject:

Publish subjects được sử dụng khi bạn chỉ muốn subscribers được thông báo về các sự kiện mới từ thời điểm bạn subscribe cho đến khi hủy subscribe hoặc Subject đã chấm dứt với sự kiện khi .completed hoặc .error
Để hiểu sâu hơn về cách thức hoạt động của PublishSubject chúng ta hãy cùng theo dõi một ví dụ
let bag = DisposeBag()
let publishSubject = PublishSubject<String>() //khởi tạo một PublishSubject kiểu String

publishSubject.onNext("Emit 1") //Phát ra một emit với chuỗi String "Emit 1"
        
let subscriberOne = publishSubject.subscribe { element in //tạo ra một Subscriber để lắng nghe sự kiện từ subject
    print("subscriber 1: \(element)")
}
subscriberOne.disposed(by: bag)
        
publishSubject.onNext("Emit 2") //Phát ra một emit với chuỗi String "Emit 2"
publishSubject.onNext("Emit 3") //Phát ra một emit với chuỗi String "Emit 3"
Chúng ta thu được kết quả như sau
subscriber 1: next(Emit 2)
subscriber 1: next(Emit 3)
*Lưu ý: Tất cả các subject khi đã terminate thì vẫn re-emit stop event cho các subscriber mới trong tương lai. Chúng ta có thể thấy rõ điều đó thông qua ví dụ sau
let bag = DisposeBag()
let publishSubject = PublishSubject<String>() //khởi tạo một PublishSubject kiểu String
        
publishSubject.onNext("Emit 1") //Phát ra một emit với chuỗi String "Emit 1"
        
let subscriberOne = publishSubject.subscribe { element in //tạo ra một Subscriber để lắng nghe sự kiện từ subject
    print("subscriber 1: \(element)")
}
subscriberOne.disposed(by: bag)
        
publishSubject.onNext("Emit 2") //Phát ra một emit với chuỗi String "Emit 2"
publishSubject.onNext("Emit 3") //Phát ra một emit với chuỗi String "Emit 3"
publishSubject.onCompleted() //terminate Subject 
        
print("- - - - - - -")
        
let subscriberTwo = publishSubject.subscribe { element in //tạo ra một Subscriber mới
    print("subscriber 2: \(element)")
}
subscriberTwo.disposed(by: bag)
Kết quả
subscriber 1: next(Emit 2)
subscriber 1: next(Emit 3)
subscriber 1: completed
- - - - - - -
subscriber 2: completed

3.2 BehaviorSubject:

BehaviorSubject hoạt động tương tự như PublishSubject, nhưng chỉ khác ở chỗ BehaviorSubject khởi đầu với một giá trị và replay lại giá trị đó hoặc .next event cuối cùng của observable cho một Subscriber mới.
Chúng ta cũng theo dõi ví dụ sau
let bag = DisposeBag()
let behaviorSubject = BehaviorSubject<String>(value: "Initial Value") //Khởi tạo một BehaviorSubject kiểu String với giá trị ban đầu là "Initial Value"
        
behaviorSubject.onNext("Emit 1") //Phát ra một emit với giá trị "Emit 1"
        
print("- Subscribe here -")
let subscriber = behaviorSubject.subscribe { element in //Subscribe subject
    print("Subscriber: \(element)")
}
subscriber.disposed(by: bag)
        
behaviorSubject.onNext("Emit 2")
behaviorSubject.onNext("Emit 3")
Chúng ta thu được kết quả
- Subscribe here -
Subscriber: next(Emit 1)
Subscriber: next(Emit 2)
Subscriber: next(Emit 3)
Subscriber vẫn nhận được "Emit 1" bởi tại thời điểm nó subscribe thì "Emit 1" chính là element cuối cùng trong Observable của subject nên subject đã replay lại element này cho subscriber.

3.3 ReplaySubject:

Được khởi tạo với một kích thước bộ đệm và sẽ chứa số lượng các emit gần nhất bằng với kích thước bộ đệm đã khai báo. ReplaySubject sẽ replay lại tất cả các emit trong bộ đệm cho subscriber ngay khi subscriber đăng ký.
Để hiểu rõ hơn về cơ hế hoạt động của ReplaySubject, chúng ta cùng theo dõi ví dụ dưới
let bag = DisposeBag()
let replaySubject = ReplaySubject<String>.create(bufferSize: 2) //khởi tạo một ReplaySubject kiểu String với size của buffer là 2
        
replaySubject.onNext("Emit 1") //Phát ra một emit với String "Emit 1"
replaySubject.onNext("Emit 2") //Phát ra một emit với String "Emit 2"
replaySubject.onNext("Emit 3") //Phát ra một emit với String "Emit 3"
        
print("- Before subscribe -")
let subscriber = replaySubject.subscribe { element in //tạo ra một Subscriber để lắng nghe sự kiện từ replaySubject
    print("Subscriber: \(element)")
}
subscriber.disposed(by: bag)
print("- After subscribe -")
        
replaySubject.onNext("Emit 4")
replaySubject.onNext("Emit 5")
Chúng ta được kết quả
- Before subscribe -
Subscriber: next(Emit 2)
Subscriber: next(Emit 3)
- After subscribe -
Subscriber: next(Emit 4)
Subscriber: next(Emit 5)
Giờ chúng ta thử tăng buffer size lên 3 trong đoạn code trên xem thu được kết quả ra sao nhé
let replaySubject = ReplaySubject<String>.create(bufferSize: 3)
Kết quả
- Before subscribe -
Subscriber: next(Emit 1)
Subscriber: next(Emit 2)
Subscriber: next(Emit 3)
- After subscribe -
Subscriber: next(Emit 4)
Subscriber: next(Emit 5)

3.4 Variable:

Lưu trữ dữ liệu hiện tại của BehaviorSubject như một state và replay duy nhất giá trị khởi tạo hoặc giá trị cuối cùng của dữ liệu cho subscriber mới.
let bag = DisposeBag()
let variableSubject = Variable("Initial Value") //Khởi tạo một Variable với giá trị khởi tạo là "Initial Value"
        
let subscriber = variableSubject.asObservable()
    .subscribe { value in
        print("Subscriber: \(value)")
    }
subscriber.disposed(by: bag)
        
variableSubject.value = "New value"
Kết quả
Subscriber: next(Initial Value)
Subscriber: next(New value)
Tuy nhiên, Variable trong tương lai sẽ không còn được sử dụng thay vào đó chúng ta sẽ sử dụng BehaviorRelay. BehaviorRelay nằm trong RxCocoa, nhưng nó tương tự như Variable, chỉ khác về mặt cú pháp khai báo và sử dụng nó.
let bag = DisposeBag()
let behaviorRelay = BehaviorRelay<Bool>(value: false)
        
let subscriber = behaviorRelay.asObservable()
    .subscribe { element in
        print("Subscriber: \(element)")
    }
subscriber.disposed(by: bag)
        
behaviorRelay.accept(false)
behaviorRelay.accept(true)
Kết quả
Subscriber: next(false)
Subscriber: next(false)
Subscriber: next(true)

Comments

Post a Comment

Popular posts from this blog

Swift GCD part 1: Thread safe singletons

Preview Singletons are entities, referenced to the same instance of a class from everywhere in your code. It doesn't matter if you like them or not, you will definitely meet them, so it's better to understand how they work. Constructing and handling a set of data doesn't seem to be a big challenge at first glance. The problems appear when you try to optimise the user experience with background work and your app starts acting weird. ??‍♂️ After decades of watching your display mostly with a blank face, you finally realize that your data isn't handled consistently by the manager because you're accessing it (running tasks on it) from multiple threads at the same time. So you really do have to deal with making your singletons thread safe. This article series is dedicated to thread handling using Swift. In the first part below you will get a comprehensive insight into som...
Post a Comment
Read more

Thread safe singleton’s in Swift

What are singletons? — Singleton is design patterns which says that there should be only one instance of the class for the lifetime of the application. One the best example of Singleton is AppDelegate . How to write a singleton class ? class DefaultDict{ private var dict:[String:Any] = [:] public static let sharedManager = DefaultDict() private init(){ } public func set(value:Any,key:String){ dict[key] = value } public func object(key:String) -> Any?{ dict[key] } public func reset(){ dict.removeAll() } }   Testing singleton class under concurrent circumstances. We are going to write an example where we will set values in dict from various threads and even try to access some with different threads. When we do this we will encounter a crash. If you look closely it will be because of race condition and the crash will be on line set(value:Any,key:String) . class ViewController: UIViewController { ...
Post a Comment
Read more

Kiến thức cơ bản về RxSwift

Bài viết với mong muốn cung cấp thông tin cơ bản về kiến trúc, các thuật ngữ được sử dụng phổ biến về RxSwift, giúp những lập trình viên lần đầu làm quen RxSwift sẽ trở nên dễ dàng hơn. Trong bài viết có sử dụng một số từ khóa tiếng Anh, mình xin phép sẽ giữ nguyên bản không sử dụng tiếng Việt vì có lẽ sẽ dễ hiểu hơn cho người đọc. Observable Sequences Mọi hoạt động trong RxSwift từ việc đăng ký và xử lý sự kiện đều thông qua một Observable Sequences Trong RxSwift , các kiểu dữ liệu như Arrays , Strings hoặc Dictionary sẽ được convert sang Observable Sequences . Ta có thể tạo ra "Observable Sequences" của bất kỳ kiểu đối tượng nào tuân theo Sequence Protocol của Swift Standard Library . let helloSequence = Observable.just( "Hello Rx" ) let fibonacciSequence = Observable. from ([ 0 , 1 , 1 , 2 , 3 , 5 , 8 ]) let dictSequence = Observable. from ([ 1 : "Hello" , 2 : "World" ]) Đăng ký nhận event từ ""Observable Se...
Post a Comment
Read more