无法使用自定义 DelegateProxy 和协议接收事件
Cannot receive event with custom DelegateProxy and Protocol
我尝试将 DifficultyViewDelegate 的委托迁移到可观察的。这是我的 DifficultyViewDelegate :
@objc protocol DifficultyViewDelegate: class {
func levelDidIncrease()
func levelDidDecrease()
}
还有我的难度视图:
weak var delegate: DifficultyViewDelegate?
@IBAction func decreaseLevel(_ sender: Any) {
delegate?.levelDidDecrease()
}
@IBAction func increaseLevel(_ sender: Any) {
delegate?.levelDidIncrease()
}
这是我的 RxDifficultyViewDelegateProxy
class RxDifficultyViewDelegateProxy: DelegateProxy, DelegateProxyType {
static func currentDelegateFor(_ object: AnyObject) -> AnyObject? {
let difficultyView: DifficultyView = object as! DifficultyView
return difficultyView.delegate
}
static func setCurrentDelegate(_ delegate: AnyObject?, toObject object: AnyObject) {
let difficultyView: DifficultyView = object as! DifficultyView
difficultyView.delegate = delegate as? DifficultyViewDelegate
}
}
我还在我的 DifficultyView 上添加了一个扩展:
extension DifficultyView {
public var rx_delegate: RxDifficultyViewDelegateProxy {
return RxDifficultyViewDelegateProxy.proxyForObject(RxDifficultyViewDelegateProxy.self)
}
public var rx_levelDidIncrease: Observable<Void> {
return rx_delegate.methodInvoked(#selector(DifficultyViewDelegate.levelDidIncrease)).map { _ in return }
}
}
但似乎当我这样做时:
difficultyView.rx_levelDidIncrease.asObservable().subscribe(onNext: {
print("did increase")
}).addDisposableTo(disposeBag)
从未调用过。有人有任何指示吗?
尝试使用 PublishSubject
:
难度查看:
class DifficultyView: UIView {
var levelDidIncrease = PublishSubject<Void>()
var levelDidDecrease = PublishSubject<Void>()
@IBAction func decreaseLevel(_ sender: Any) {
levelDidDecrease.onNext()
}
@IBAction func increaseLevel(_ sender: Any) {
levelDidIncrease.onNext()
}
}
然后:
var difficultyView = DifficultyView()
difficultyView.levelDidDecrease.asObservable()
.subscribe(onNext: {
print("did decrease")
})
.addDisposableTo(disposeBag)
difficultyView.decreaseLevel(theSender) // <- THIS line performs the side effect
我尝试将 DifficultyViewDelegate 的委托迁移到可观察的。这是我的 DifficultyViewDelegate :
@objc protocol DifficultyViewDelegate: class {
func levelDidIncrease()
func levelDidDecrease()
}
还有我的难度视图:
weak var delegate: DifficultyViewDelegate?
@IBAction func decreaseLevel(_ sender: Any) {
delegate?.levelDidDecrease()
}
@IBAction func increaseLevel(_ sender: Any) {
delegate?.levelDidIncrease()
}
这是我的 RxDifficultyViewDelegateProxy
class RxDifficultyViewDelegateProxy: DelegateProxy, DelegateProxyType {
static func currentDelegateFor(_ object: AnyObject) -> AnyObject? {
let difficultyView: DifficultyView = object as! DifficultyView
return difficultyView.delegate
}
static func setCurrentDelegate(_ delegate: AnyObject?, toObject object: AnyObject) {
let difficultyView: DifficultyView = object as! DifficultyView
difficultyView.delegate = delegate as? DifficultyViewDelegate
}
}
我还在我的 DifficultyView 上添加了一个扩展:
extension DifficultyView {
public var rx_delegate: RxDifficultyViewDelegateProxy {
return RxDifficultyViewDelegateProxy.proxyForObject(RxDifficultyViewDelegateProxy.self)
}
public var rx_levelDidIncrease: Observable<Void> {
return rx_delegate.methodInvoked(#selector(DifficultyViewDelegate.levelDidIncrease)).map { _ in return }
}
}
但似乎当我这样做时:
difficultyView.rx_levelDidIncrease.asObservable().subscribe(onNext: {
print("did increase")
}).addDisposableTo(disposeBag)
从未调用过。有人有任何指示吗?
尝试使用 PublishSubject
:
难度查看:
class DifficultyView: UIView {
var levelDidIncrease = PublishSubject<Void>()
var levelDidDecrease = PublishSubject<Void>()
@IBAction func decreaseLevel(_ sender: Any) {
levelDidDecrease.onNext()
}
@IBAction func increaseLevel(_ sender: Any) {
levelDidIncrease.onNext()
}
}
然后:
var difficultyView = DifficultyView()
difficultyView.levelDidDecrease.asObservable()
.subscribe(onNext: {
print("did decrease")
})
.addDisposableTo(disposeBag)
difficultyView.decreaseLevel(theSender) // <- THIS line performs the side effect