RxSwift – Behavior Subjects

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")

    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")

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")

🔵  next(0)
🔵  next(1)

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

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)

🔵  next(0)
🔵  next(1)
🔴  next(1)
🔵  error(anError)
🔴  error(anError)
🟠  error(anError)

    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!

Written by chuotfx