我是RxSwift的新手,需要一个非常基本的帮助.
假设我有一个Observable并按这样订阅它.
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 {
}
}
Run Code Online (Sandbox Code Playgroud)
订阅如下:
source.subscribeNext { () -> Void in
}
Run Code Online (Sandbox Code Playgroud)
问题是:如何在每次需要时手动将事件发送到subscribeNext.这就像rx_tap行为一样UIButton.
我在示例中看到代码有这样的东西source = button.rx_tap.asObservale().之后,每次用户点击按钮时,都会在subscribeNext()上发出一个事件并触发.我也希望这种行为,但在程序上,而不是从UI事件.