Привязка делегата RxSwift не генерируется? - PullRequest
Новая
       71

Привязка делегата RxSwift не генерируется?

0 голосов
/ 03 февраля 2020

Я пытаюсь связать делегата, вот что было сделано 

/** Delegate Proxy **/
func castOrThrow<T>(_ resultType: T.Type, _ object:Any) throws -> T {
    guard let returnValue = object as? T else {
        throw RxCocoaError.castingError(object: object, targetType: resultType)
    }
    return returnValue
}
@objc
public protocol TestEventGeneratorDelegate:class {
    @objc optional func asyncEventResult(int:Int)
}
open class TestEventGenerator {
    public var delegate: TestEventGeneratorDelegate?
    func asyncCall() {
        DispatchQueue.global().asyncAfter(deadline: .now() + .seconds(1)) { [weak self] in
            guard let self = self else  { return }
            self.delegate?.asyncEventResult!(int: 0)
        }
    }
}
extension TestEventGenerator: HasDelegate {
    public typealias Delegate = TestEventGeneratorDelegate
}
open class RxTestDelegateProxy : DelegateProxy<TestEventGenerator,TestEventGeneratorDelegate>,
                                DelegateProxyType,
                                TestEventGeneratorDelegate {
    public weak private(set) var testGenerator: TestEventGenerator?
    public init(testEventGenerator: ParentObject) {
        self.testGenerator = testEventGenerator
        super.init(parentObject: testEventGenerator, delegateProxy: RxTestDelegateProxy.self)
    }
    public static func registerKnownImplementations() {
        self.register { RxTestDelegateProxy(testEventGenerator: $0) }
    }
}
extension Reactive where Base: TestEventGenerator {
    public var delegate: DelegateProxy<TestEventGenerator, TestEventGeneratorDelegate> {
        return RxTestDelegateProxy.proxy(for: base)
    }
    public var asyncEventResult: Observable<Int> {
        let source =  delegate.methodInvoked(#selector(TestEventGeneratorDelegate.asyncEventResult(int:)))
        .map { (a) in
            return try castOrThrow(Int.self,a[0])
        }
        return source
    }
}
/**  Delegate Proxy **/

Затем, когда я его использую 

let testEventGenerator = TestEventGenerator()
textEventGenerator.rx.asyncEventResult.subscribe.... // subscribe here no rx found? 
testEventGenerator.asyncCall() // call and wait for the observable to return to the delegate

Он не компилируется и говорит, что такого rx нет

Я должен связать это, потому что человек, который написал API, не использовал обратный вызов для возврата значения, а скорее делегат.

Это пример того, как он написал код и как Я хочу обернуть его.

Есть ли способ связать делегата, который требует удаления из asyncCall ()?

чтобы я мог связать его, используя flatmapLatest, в обещании, как обещание?

Спасибо, дайте мне знать!

Я следовал этому уроку: Как преобразовать Delegate в Observable RxSwift ? и https://blog.ippon.fr/2018/11/13/rxswift-how-to-make-your-favorite-delegate-based-apis-reactive/

1 Ответ

0 голосов
/ 03 февраля 2020

соответствуют TestEventGenerator: ReactiveCompatible, и это исправит это.

...