1. Khái niệm

Relay là thành phần mới được thêm vào RxSwift. Đi kèm với đó là khai tử đi Variable , một trong nhưng Class sử dụng rất nhiều trong các project với RxSwift.

Thứ nhất, Relay là một wraps cho một subject. Tuy nhiên, nó không giống như các subject hay các observable chung chung. Ở một số đặc điểm sau:

• Không có hàm .onNext(_:) để phát đi dữ liệu

• Dữ liệu được phát đi bằng cách sử dụng hàm .accept(_:)

• Chúng sẽ không bao giờ .error hay .completed Ta có 2 loại Relay:

• PublishRelay đó là warp của PublishSubject. Relay này mang đặc tính của PublishSubject

• BehaviorRelay đó là warp của BehaviorSubject. Nó sẽ mang các đặc tính của subject này

2. Publish Relays

Create

import RxCocoa

    // dispose
    let disposeBag = DisposeBag()
    // error define
    enum MyError: Error {
      case anError
    }
    
    // relay
    let publishRelay = PublishRelay<String>()

Bạn sẽ có một đối tượng publishRelay thuộc class PublishRelay. Việc khởi tạo thì không cần cung cấp giá trị nào hết. Bạn cần phải cung cấp kiểu dữ liệu cho các phần tử được phát đi, trong trường hợp này là String.

Emit

publishRelay.accept("0")

Lần này, sẽ khác cách Subject emit dữ liệu đi. Bạn sử dụng .accept thay cho .onNext.

Subscribe

  // subcribe 1
    publishRelay
      .subscribe { print("🔵 ", $0) }
      .disposed(by: disposeBag)
    
    // emits
    publishRelay.accept("1")
    publishRelay.accept("2")
    publishRelay.accept("3")
    
    // subcribe 2
    publishRelay
      .subscribe { print("🔴 ", $0) }
      .disposed(by: disposeBag)
    
    // emit
    publishRelay.accept("4")

Output:

🔵  next(1)
🔵  next(2)
🔵  next(3)
🔵  next(4)
🔴  next(4)

Vẫn là function .subcribe() để đăng ký tới 1 Relay. Trong ví dụ này, subscriber sẽ nhận được các giá trị mới sau khi nó đăng ký. Còn subscribe2, chỉ nhận được giá trị 4 thôi.

Terminate

Bạn không thể kết thúc Relay được, vì chúng không hề phát đi error hay completed. Việc phát đi error & completed thì đều bị trình biên dịch ngăn cản.

       let test1 =  publishRelay
               .subscribe { print("test1 ", $0) }

           // emits
           publishRelay.accept("1")
           publishRelay.accept("2")
            test1.dispose()
           publishRelay.accept("3")

Tương tự như Publish Subjects, khi subscribe gọi .dispose() thì cũng sẽ thì sẽ không nhận được các giá trị mà subject phát tiếp.

3. Behavior Relays

Create

let behaviorRelay = BehaviorRelay<String>(value: "0")

Class tạo ra 1 Relay này là BehaviorRelay. Tương tự, bạn phải cung cấp một giá trị cho value để làm giá trị khởi tạo ban đầu cho Relay này.

Emit

behaviorRelay.accept("0")

Subscribe

  // subcribe 1
    behaviorRelay
      .subscribe { print("🔵 ", $0) }
      .disposed(by: disposeBag)
    
    behaviorRelay.accept("1")
    behaviorRelay.accept("2")
    behaviorRelay.accept("3")
    
    // subcribe 2
    behaviorRelay
      .subscribe { print("🔴 ", $0) }
      .disposed(by: disposeBag)
    
    behaviorRelay.accept("4")

Output:

🔵  next(0)
🔵  next(1)
🔵  next(2)
🔵  next(3)
🔴  next(3)
🔵  next(4)
🔴  next(4)

Nhìn qua, nó cũng không khác các Observables & Subject. Và nó tuân theo đặc tính của Behavior Subject, sẽ luôn nhận được giá trị mới nhất khi có 1 Subscriber mới đăng ký tới.

Terminate

Tương tự như Publish Relays, khi subscribe gọi .dispose() thì cũng sẽ thì sẽ không nhận được các giá trị mà subject phát tiếp. Bạn không thể kết thúc Relay được, vì chúng không hề phát đi error hay completed. Việc phát đi error & completed thì đều bị trình biên dịch ngăn cản.

Value

Một điều đặc biệt của Behavior Relay là bạn có thể lấy được giá trị hiện tại được lưu trữ trong Relay. Cách lấy như sau:

 print("Current value: \(behaviorRelay.value)")

Output:

Current value: 4

.value chính là đặc tính mà để Behavior Relay thay thế Variable

Tham khảo: https://fxstudio.dev/rxswift-relays/