Skip to content
  • Home
  • Code
  • iOS & Swift
  • Combine
  • RxSwift
  • SwiftUI
  • Tutorials
  • Art
  • Blog
Fx Studio
  • Home
  • Code
  • iOS & Swift
  • Combine
  • RxSwift
  • SwiftUI
  • Tutorials
  • Art
  • Blog
Written by chuotfx on September 13, 2020

RxSwift – Behavior Subjects

RxSwift

Contents

  • Chuẩn bị
  • 1. Khái niệm Behavior Subjects
  • 2. Hoạt động
    • 2.1. Create Behavior Subjects
    • 2.2. Emit
    • 2.3. Subscribe
    • 2.4. Terminate
  • Tạm kết

Chào bạn đến với Fx Studio. Trong bài viết trước, chúng ta đã đi qua Publish Subjects rồi. Và bài viết này sẽ trình bày về một loại Subject nữa trong vũ trụ RxSwift. Đó là Behavior Subjects.

Trước tiên, bạn cần phải nắm được các kiến thức sau:

    • RxSwift – Observables
    • RxSwift – Hello Subjects

Đó là 2 phần lý thuyết mà đi theo bạn khá lâu đó. Còn nếu mọi thứ đã ổn rồi thì …

Bắt đầu thôi!

Chuẩn bị

    • Xocde 11
    • Swift 5.x
    • Playground

Vẫn là em Playground huyền thoại. Chúng ta vẫn còn dùng tới nó để demo code cho bài viết này. Bạn chỉ cần tạo mới 1 file Playground từ project mà đã cài đặt ngay từ bài đầu của series. Bạn có thể checkout code lại đây.

1. Khái niệm Behavior Subjects

Đó là sơ đồ marble để mô tả cho Behavior Subjects. Bạn thấy có điểm gì đặc biệt ở đây không? Hãy chú ý tới các mũi tên subscribe(). Khi đó, subject sẽ phát đi dữ liệu mới nhất lại cho subscriber.

Vậy Behavior Subject là gì?

Nó cũng là một loại Subject và cũng tương tự như Publish Subject. Tuy nhiên, có chỗ khác biệt là Behavior Subjects sẽ luôn cung cấp giá trị cuối cùng mà nó phát ra cho các subscriber khi đăng kí tới.

Kkông cần quan tâm tới thời điểm mà subscriber đăng ký tới, cứ hễ có đăng kí là sẽ nhận được giá trị từ subject.

Ta có các đặc điểm sau của loại Subject này:

  • Luôn luôn cung cấp giá trị cho phần tử của subject khi khởi tạo subject.
  • Các subscriber khi subscribe tới subject, thì luôn nhận được giá trị mới nhất.

2. Hoạt động

2.1. Create Behavior Subjects

Chuyển sang xem code ví dụ cho dễ hiểu hơn nào. Bắt đầu bằng việc khai báo 1 Behavior Subject. Bạn hãy tạo thêm 1 file Playground để demo code cho phần này. Hoặc dùng lại ở bài trước cũng được. Không quá nhiều code đâu.

Thêm dòng code này vào.

let subject = BehaviorSubject(value: "0")

Ta đã tạo 1 đối tượng là subject với kiểu BehaviorSubject. Bạn không cần phải khai báo kiểu dữ liệu cho phần tử của subject. Vì chúng sẽ tự động suy ra từ giá trị của tham số value mà bạn truyền vào. Trong trường hợp này chính là String.

Tiếp theo ví dụ, khai báo thêm túi rác quốc dân & enum define cho mã lỗi.

    let disposeBag = DisposeBag()
    
    enum MyError: Error {
      case anError
    }

Xong các thủ tục cần thiết rồi!

2.2. Emit

subject.onNext("1")

Để emit dữ liệu thì cũng không khác gì Publish Subjects. Bạn chỉ cần gọi .onNext và truyền dữ liệu vào thôi.

2.3. Subscribe

Quay lại với file Playground của bạn, hãy tiến hành subcribe ngay sau việc khai báo đối tượng subject trên.

    //subscribe
    subject .subscribe {
        print("🔵 ", $0)
      }
    .disposed(by: disposeBag)

    // emit
    subject.onNext("1")

Đoạn code subscribe trên nhằm kiểm tra thử việc chúng ta có nhận được giá trị ban đầu khi cấp cho Behavior Subject không. Thực thi đoạn code và xem kết quả nào
🔵  next(0)
🔵  next(1)

Bạn sẽ thấy subscribe đầu tiên nhận hết các giá trị được phát ra từ subject. Và bạn tiếp tục thêm 1 subscriber nữa để xem sao.
subject .subscribe {
        print("🔴 ", $0)
      }
    .disposed(by: disposeBag)

Lúc này thì subscriber thứ 2 nhận được giá trị 1. Do lúc này 1 là mới nhất.

2.4. Terminate

Cuối cùng, ta kết thúc subject với 1 .error.

    // error
    subject.onError(MyError.anError)
    
    //Subscribe 3
    subject .subscribe {
        print("🟠 ", $0)
      }
    .disposed(by: disposeBag)

Lúc này, 2 subscriber trước đó sẽ nhận .error và subscriber mới sẽ nhận được error. Ta xem kết quả như sau:
🔵  next(0)
🔵  next(1)
🔴  next(1)
🔵  error(anError)
🔴  error(anError)
🟠  error(anError)

Với Behavior Subject này thì cũng không quá hack não! Full code ví dụ trên cho bạn có hình dung tổng quát:
    let disposeBag = DisposeBag()
    
    enum MyError: Error {
      case anError
    }
    
    let subject = BehaviorSubject(value: "0")
    
    //Subscribe 1
    subject .subscribe {
        print("🔵 ", $0)
      }
    .disposed(by: disposeBag)
    
    // emit
    subject.onNext("1")
    
    //Subscribe 2
    subject .subscribe {
        print("🔴 ", $0)
      }
    .disposed(by: disposeBag)
    
    // error
    subject.onError(MyError.anError)
    
    //Subscribe 3
    subject .subscribe {
        print("🟠 ", $0)
      }
    .disposed(by: disposeBag)

 

OKAY! Mình xin kết thúc bài viết này tại đây. Nếu có gì thắc mắc hay góp ý cho mình thì bạn có thể để lại bình luận hoặc gởi email theo trang Contact. Hẹn bạn ở các bài viết sau.

Tạm kết

  • Behavior Subject sẽ phát đi các giá trị cuối cùng của nó cho các subscirber khi đăng ký tới nó.
  • Đảm bảo các subscriber luôn nhận được giá trị khi đăng ký tới
  • Phải cung cấp giá trị ban đầu khi khởi tạo subject
  • Khi subject kết thúc thì các subcriber mới sẽ nhận được .error hay .completed.

 

Cảm ơn bạn đã đọc bài viết này!

FacebookTweetPinYummlyLinkedInPrintEmailShares8

Related Posts:

  • RxSwift vs. UIKit – Working with Cache DataRxSwift vs. UIKit – Working with Cache Data
  • RxSwift - Phần 1 : Cơ bảnRxSwift - Phần 1 : Cơ bản
  • RxSwift - Combining OperatorsRxSwift - Combining Operators
  • RxSwift vs. UIKit - Fetching Data from APIRxSwift vs. UIKit - Fetching Data from API
Tags: rxswift
Written by chuotfx

Leave a Reply Cancel reply

Your email address will not be published. Required fields are marked *

Recent Posts

  • Tổng hợp về Protocol & Closure trong iOS
  • Delegates vs. Closure Callback
  • Protocol vs. Closure – Asynchronous
  • Protocol vs. Closure – Passing Data
  • RxSwift – Phần 3 : RxCocoa Basic

Fan page

Fx Studio

Archives

  • January 2021 (2)
  • December 2020 (3)
  • November 2020 (9)
  • October 2020 (7)
  • September 2020 (17)
  • August 2020 (1)
  • July 2020 (3)
  • June 2020 (1)
  • May 2020 (2)
  • April 2020 (3)
  • March 2020 (20)
  • February 2020 (5)
  • January 2020 (2)
  • December 2019 (12)
  • November 2019 (12)
  • October 2019 (19)
  • September 2019 (17)
  • August 2019 (10)

Tags

api AppDistribution applecard arkit autolayout basic ios tutorial blog bundle button Certificate ci/cd closure cocoapod collectionview combine crashlytics darkmode delegate deploy fabric fastlane firebase GCD gestures gradients iOS LinterBot List MVVM playground protocol Provisioning Reality Composer rxswift safearea storyboard Swift swiftlint SwiftUI tableview TravisCI Trigger videos xcconfig xcode11

You may also like:

  • RxSwift - Replay SubjectsRxSwift - Replay Subjects
  • RxSwift - Hello SubjectsRxSwift - Hello Subjects
  • RxSwift - Hello world!RxSwift - Hello world!
  • RxSwift - Transforming OperatorsRxSwift - Transforming Operators
  • RxSwift - DisposeBagRxSwift - DisposeBag

About me

Education, Mini Game, Digital Art & Life of coders
Contacts:
contacts@fxstudio.dev

Fx Studio

  • Home
  • About me
  • Contact us
  • Mail
  • Privacy Policy
  • Sitemap

Categories

  • Art (1)
  • Blog (15)
  • Code (4)
  • Combine (22)
  • iOS & Swift (44)
  • RxSwift (34)
  • SwiftUI (8)
  • Tutorials (32)

Newsletter

Stay up to date with our latest news and posts.
Loading

Copyright © 2021 Fx Studio - All rights reserved.

Share this ArticleLike this article? Email it to a friend!

Email sent!