Phát hiện sự kiện theo cách thủ công trong RxSwift

Question

Tôi là người mới trong RxSwift và cần trợ giúp rất cơ bản.
Giả sử rằng tôi có một Đài quan sát và đăng ký nó như thế này.

let source: Observable<Void> = Observable.create { [weak self] observer in 

     guard let _ = self else { 
      observer.on(.Completed) 
      return NopDisposable.instance 
     } 

     observer.on(.Next()) 

     return AnonymousDisposable { 

     } 
    } 

Và đăng ký như thế này:

source.subscribeNext {() -> Void in 

    } 

Câu hỏi đặt ra là: làm thế nào tôi có thể phát ra sự kiện để subscribeNext bằng tay mỗi khi tôi cần. Điều này giống như hành vi rx_tap trên UIButton.
Tôi thấy trong mã ví dụ có một cái gì đó như thế này source = button.rx_tap.asObservale(). Sau đó, mỗi lần người dùng chạm vào nút, sẽ phát ra một sự kiện và kích hoạt trên subscribeNext(). Tôi cũng muốn có hành vi đó nhưng theo lập trình, không phải từ sự kiện giao diện người dùng.

Answer 1

Hầu hết thời gian, bạn có thể soạn quan sát và giải pháp mà tôi sắp đưa ra không phải là cách được khuyến nghị để làm mã Rx.

Bạn có thể xem Subject để triển khai hành vi bạn yêu cầu. Có nhiều biến thể về chủ đề, tài liệu giải thích rõ ràng.

Một ví dụ sử dụng, lấy cảm hứng từ RxSwift của playground:

let subject = PublishSubject<String>() 

_ = subject.subscribeNext { content in 
    print(content) 
} 
subject.on(.Next("a")) 
subject.on(.Next("b")) 

này sẽ in "a" sau đó "b".

Để biết thêm chi tiết về thời điểm sử dụng chủ đề hay không, tôi khuyên bạn nên đọc this article.

Answer 2

Đối với một điều khiển, bạn có thể làm việc

var isSearching: Driver<Bool> 

isSearching = Driver.just(true)