RxSwift Extension that support two way binding with Eureka.

Eureka RxSwift.swift

extension RowOf: ReactiveCompatible {}

extension Reactive where Base: RowType, Base: BaseRow {
    var value: ControlProperty<Base.Cell.Value?> {
        let source = Observable<Base.Cell.Value?>.create { observer in
            self.base.onChange { row in
                observer.onNext(row.value)
            }
            return Disposables.create()
        }
        let bindingObserver = UIBindingObserver(UIElement: self.base) { (row, value) in
            row.value = value
        }
        return ControlProperty(values: source, valueSink: bindingObserver)
    }
}

@dangthaison91 - would you please show how this would be used?

@jcmendez: Really sorry for didn't reply soon. for Eureka 3.0 and RxSwift 3.x you should go with this. I just refactor for my project today:

extension RowOf: ReactiveCompatible {}

extension Reactive where Base: RowType, Base: BaseRow {
    var value: ControlProperty<Base.Cell.Value?> {
        let source = Observable<Base.Cell.Value?>.create { observer in
            self.base.onChange { row in
                observer.onNext(row.value)
            }
            return Disposables.create()
        }
        let bindingObserver = UIBindingObserver(UIElement: self.base) { (row, value) in
            row.value = value
        }
        return ControlProperty(values: source, valueSink: bindingObserver)
    }
}

So you can easily do 2way-binding or get row's value via Rx extensions:

someRow.rx.value.bind(to: someVariable)
OR
someRow.rx.value <-> someVariable

Can you do an update for this code to be compatible with the latest RxSwift. Variable is getting deprecated soon. thank you..

swift5.1 version
https://gist.github.com/AwayQu/16e6a80d3e8c69984e78069f7bd565ab

I found a memory leak, here's the fixed version:

extension Eureka.RowOf: ReactiveCompatible {}

extension Reactive where Base: Eureka.RowType, Base: Eureka.BaseRow {
    var value: ControlProperty<Base.Cell.Value?> {
        let source = Observable<Base.Cell.Value?>.create { [weak base] observer in
            if let _base = base {
                observer.onNext(_base.value)
                _base.onChange { row in
                    observer.onNext(row.value)
                    row.updateCell()
                }
            }
            return Disposables.create()
        }
        let bindingObserver = Binder(self.base) { (row, value) in
            row.value = value
        }
        return ControlProperty(values: source, valueSink: bindingObserver)
    }
}