RxSwift: working with a GUI

var rx_driveCoordinates: AnyObserver {
    let observer = UIBindingObserver(UIElement: self) { label, location in
        label.text = "Lat: \(location.latitude)\nLon: \(location.longitude)"
    }
    return observer.asObserver()
}

var rx_driveCoordinates: AnyObserver {
    let uiBindingObserver: UIBindingObserver = UIBindingObserver(UIElement: self) { label, location in
        label.text = "Lat: \(location.latitude)\nLon: \(location.longitude)"
    }
    return uiBindingObserver.asObserver()
}

var rx_wasError: AnyObserver {
    return UIBindingObserver(UIElement: self) { label, error in
        label.textColor = error ? UIColor.redColor() : UIColor.blackColor()
        }.asObserver()
}

var rx_driveCoordinatesUIB: UIBindingObserver {
    return UIBindingObserver(UIElement: self) { label, location in
        label.text = "Lat: \(location.latitude)\nLon: \(location.longitude)"
        }
}

private extension UIView {
    var rx_driveAuthorization: AnyObserver {
        return UIBindingObserver(UIElement: self) { view, authorized in
            if authorized {
                view.hidden = true
                view.superview?.sendSubviewToBack(view)
            }
            else {
                view.hidden = false
                view.superview?.bringSubviewToFront(view)
            }
        }.asObserver()
    }
}

Controlvent

extension UIButton {
    /**
    Reactive wrapper for `TouchUpInside` control event.
    */
    public var rx_tap: ControlEvent {
		return rx_controlEvent(.TouchUpInside)
    } 
}

public func rx_controlEvent(controlEvents: UIControlEvents) -> ControlEvent {
    let source: Observable = Observable.create { [weak self] observer in
        MainScheduler.ensureExecutingOnScheduler() // убеждаемся что мы в Main потоке
        guard let control = self else { // если контрол уже не существует - генерируем .Competed 
            observer.on(.Completed)
            return NopDisposable.instance
        }
        // самое важное, создаем ControlTarget на основании текущего контрола, переданных в качестве параметров событий на который мы должны реагировать и callback который будет вызываться при срабатывании события
        let controlTarget = ControlTarget(control: control, controlEvents: controlEvents) {
            control in
            observer.on(.Next())
        }
        return AnonymousDisposable {
            controlTarget.dispose()
        }
    }.takeUntil(rx_deallocated) // заканчиваем генерировать элементы при деаллокации контрола
    return ControlEvent(events: source)
}

class GeolocationViewController: ViewController {
    @IBOutlet weak private var button: UIButton!
...
    override func viewDidLoad() {
...
        button.rx_tap
            .bindNext { [weak self] in
                self?.openAppPreferences()
            }
            .addDisposableTo(disposeBag)
...
    }
...
}

public func bindNext(onNext: E -> Void) -> Disposable {
    return subscribe(onNext: onNext, onError: { error in
        let error = "Binding error: \(error)"
        #if DEBUG
            rxFatalError(error)
        #else
            print(error)
        #endif
    })
}

Controlproperty

extension UITextField {
    /**
    Reactive wrapper for `text` property.
    */
    public var rx_text: ControlProperty {
        return UIControl.rx_value(
            self,
            getter: { textField in
                textField.text ?? ""
            }, setter: { textField, value in
                textField.text = value
            }
        )
    }
}

static func rx_value(control: C, getter: (C) -> T, setter: (C, T) -> Void) -> ControlProperty {
        let source: Observable = Observable.create { [weak weakControl = control] observer in
                guard let control = weakControl else { // если контрол уже не существует - генерируем .Competed 
                    observer.on(.Completed)
                    return NopDisposable.instance
                }
                observer.on(.Next(getter(control))) // сразу генерируем новый элемент последовательности на основе начального значения свойства контрола посредством переданного getter'а
				// сюрприз, и снова рассмотренный ранее ControlTarget
                let controlTarget = ControlTarget(control: control as! UIControl, controlEvents: [.AllEditingEvents, .ValueChanged]) { _ in
                    if let control = weakControl {
                        observer.on(.Next(getter(control)))
                    }
                }
                return AnonymousDisposable {
                    controlTarget.dispose()
                }
            }
            .distinctUntilChanged() // срабатывает только если значение действительно поменялось
            .takeUntil((control as! NSObject).rx_deallocated) // заканчиваем генерировать элементы при деаллокации контрола
        // и снова сюрприз, старый добрый UIBindingObserver позволяет сделать привязку элементов Observable к полю через переданный setter
        let bindingObserver = UIBindingObserver(UIElement: control, binding: setter) 
        return ControlProperty(values: source, valueSink: bindingObserver)
    }
}

@IBOutlet var a: NSTextField!
@IBOutlet var b: NSTextField!
@IBOutlet var c: NSTextField!
...
override func viewDidLoad() {
...
	//Таким образом ControlProperty может выступать как в качестве Observable
    let sum = Observable.combineLatest(a.rx_text, b.rx_text) { (a: String, b: String) -> (Int, Int) in
        return (Int(a) ?? 0, Int(b) ?? 0)
    }
...
    sum
        .map { (a, b) in
            return "\(a + b)"
        }
        .bindTo(c.rx_text) //так и в качестве Observer'а
        .addDisposableTo(disposeBag)
}

infix operator <-> {
}
func <-> (property: ControlProperty, variable: Variable) -> Disposable {
    let bindToUIDisposable = variable.asObservable()
        .bindTo(property)
    let bindToVariable = property
        .subscribe(onNext: { n in
            variable.value = n
        }, onCompleted:  {
            bindToUIDisposable.dispose()
        })
    return StableCompositeDisposable.create(bindToUIDisposable, bindToVariable)
}

let textViewValue = Variable("")
textView.rx_text <-> textViewValue

DelegateProxy

public var rx_cancelButtonClicked: ControlEvent {
        let source: Observable = rx_delegate.observe(#selector(UISearchBarDelegate.searchBarCancelButtonClicked(_:)))
            .map { _ in
                return ()
            }
        return ControlEvent(events: source)
    }

searchBar.rx_cancelButtonClicked.subscribeNext { _ in
            // выполняем нужные действия
        }

class SimpleTableViewExampleViewController : ViewController {
    @IBOutlet weak var tableView: UITableView!
    override func viewDidLoad() {
        super.viewDidLoad()
        // создаем Observable  массивом элементов
        let items = Observable.just([
            "First Item",
            "Second Item",
            "Third Item"
        ])
		// связываем эти элементы с tableView (внутри автоматически создается прокси dataSource), так же указывая фабрику для создания ячеек
        items
            .bindTo(tableView.rx_itemsWithCellIdentifier("Cell", cellType: UITableViewCell.self)) { (row, element, cell) in
                cell.textLabel?.text = "\(element) @ row \(row)"
            }
            .addDisposableTo(disposeBag)
// добавляем реакцию на нажатие по строке, rx_modelSelected - обертка над tableView:didSelectRowAtIndexPath:
        tableView
            .rx_modelSelected(String)
            .subscribeNext { value in
                DefaultWireframe.presentAlert("Tapped `\(value)`")
            }
            .addDisposableTo(disposeBag)
// добавляем реакцию на нажатие по кнопки информации - обертка над tableView(_:accessoryButtonTappedForRowWithIndexPath:)
        tableView
            .rx_itemAccessoryButtonTapped
            .subscribeNext { indexPath in
                DefaultWireframe.presentAlert("Tapped Detail @ \(indexPath.section),\(indexPath.row)")
            }
            .addDisposableTo(disposeBag)
    }
}

class SimpleTableViewExampleSectionedViewController
    : ViewController
    , UITableViewDelegate {
    @IBOutlet weak var tableView: UITableView!
    let dataSource = RxTableViewSectionedReloadDataSource>()
    override func viewDidLoad() {
        super.viewDidLoad()
        let dataSource = self.dataSource
        let items = Observable.just([
            SectionModel(model: "First section", items: [
                    1.0,
                    2.0,
                    3.0
                ]),
            SectionModel(model: "Second section", items: [
                    1.0,
                    2.0,
                    3.0
                ]),
            SectionModel(model: "Second section", items: [
                    1.0,
                    2.0,
                    3.0
                ])
            ])
        dataSource.configureCell = { (_, tv, indexPath, element) in
            let cell = tv.dequeueReusableCellWithIdentifier("Cell")!
            cell.textLabel?.text = "\(element) @ row \(indexPath.row)"
            return cell
        }
        items
            .bindTo(tableView.rx_itemsWithDataSource(dataSource))
            .addDisposableTo(disposeBag)
        tableView
            .rx_itemSelected
            .map { indexPath in
                return (indexPath, dataSource.itemAtIndexPath(indexPath))
            }
            .subscribeNext { indexPath, model in
                DefaultWireframe.presentAlert("Tapped `\(model)` @ \(indexPath)")
            }
            .addDisposableTo(disposeBag)
        tableView
            .rx_setDelegate(self)
            .addDisposableTo(disposeBag)
    }
    func tableView(tableView: UITableView, viewForHeaderInSection section: Int) -> UIView? {
        let label = UILabel(frame: CGRect.zero)
        label.text = dataSource.sectionAtIndex(section).model ?? ""
        return label
    }
}

public func tableView(tableView: UITableView, observedEvent: Event) {
    UIBindingObserver(UIElement: self) { dataSource, element in
        dataSource.setSections(element)
        tableView.reloadData()
    }.on(observedEvent)
}

class TablViewControllerEditPartialUpdate : ViewController {
    @IBOutlet weak var tableView: UITableView!
    var sections = Variable([NumberSection]())
    override func viewDidLoad() {
        super.viewDidLoad()
        // NumberSection - на самом деле typealias AnimatableSectionModel
        let items = [
            NumberSection(model: "Section 1", items: [1, 3, 5]),
            NumberSection(model: "Section 2", items: [2, 4, 6, 8]),
            NumberSection(model: "Section 3", items: [7, 11, 10])
        ]
        self.sections.value = items
        let editableDataSource = RxTableViewSectionedAnimatedDataSource()
        configDataSource(editableDataSource)
        // замечу что используется rx_itemsAnimatedWithDataSource, а не rx_itemsWithDataSource
        self.sections.asObservable()
            .bindTo(tableView.rx_itemsAnimatedWithDataSource(editableDataSource))
            .addDisposableTo(disposeBag)
        // удаляем элемент из модели
        tableView.rx_itemDeleted.subscribeNext{[weak self] item in
            if let controller = self {
                controller.sections.value[item.section].items.removeAtIndex(item.row)
            }
            }.addDisposableTo(disposeBag)
        // извлекаем объект при нажатии на строку таблицы
        tableView
            .rx_modelSelected(IdentifiableValue)
            .subscribeNext { i in
                DefaultWireframe.presentAlert("Tapped `\(i)`")
            }
            .addDisposableTo(disposeBag)
        // получаем NSIndexPath при нажатии на строку таблицы, что очень помогло при определении типа объекта
        tableView
            .rx_itemSelected
            .subscribeNext { [weak self]  i in
                if let controller = self {
                    print("Tapped `\(i)` - \(controller.sections.value[i.section].items[i.row].dynamicType)")
                }
            }
            .addDisposableTo(disposeBag)
    }
    func configDataSource(dataSource: RxTableViewSectionedDataSource) {
        dataSource.configureCell = { (_, tv, ip, i) in
            let cell = tv.dequeueReusableCellWithIdentifier("Cell")
                ?? UITableViewCell(style:.Default, reuseIdentifier: "Cell")
            cell.textLabel!.text = "\(i)"
            return cell
        }
        dataSource.titleForHeaderInSection = { (ds, section: Int) -> String in
            return dataSource.sectionAtIndex(section).model
        }
        dataSource.canEditRowAtIndexPath = { (ds, ip) in
            return true
        }
    }
}

fatal error: Failure converting from  to UITableViewDataSource: file /Users/SparkLone/projects/repos/RxSwift/RxCocoa/Common/RxCocoa.swift, line 340

rx_modelSelected(IdentifiableValue)

rx_modelSelected(Int)

fatal error: Failure converting from 4 to Int: file /Users/SparkLone/projects/repos/RxSwift/RxCocoa/Common/RxCocoa.swift, line 340

tableView
    .rx_itemSelected
    .subscribeNext { [weak self]  i in
        if let controller = self {
            print("Tapped `\(i)` - \(controller.sections.value[i.section].items[i.row].dynamicType)")
        }
    }
    .addDisposableTo(disposeBag)

precondition failed: Item 3 has already been indexed at (0, 1): file /Users/SparkLone/projects/repos/RxSwift/RxExample/RxDataSources/DataSources/Differentiator.swift, line 130

protocol DelegateProxyType {
	// функция отвечающая за создание прокси
	static func createProxyForObject(object: AnyObject) -> AnyObject
 	// прикрепляем прокси к объекту посредством objc_setAssociatedObject
 	static func assignProxy(proxy: AnyObject, toObject object: AnyObject)
	// получаем прикрепленный прокси к объекту посредством objc_getAssociatedObject
    static func assignedProxyFor(object: AnyObject) -> AnyObject?
    // функции отвечающие за прикрепление / получении доступа к обычному(не Rx) делегату
    func setForwardToDelegate(forwardToDelegate: AnyObject?, retainDelegate: Bool)
    func forwardToDelegate() -> AnyObject?
    // функции отвечающие за присвоение / возврат делегату-прокси, с приведением типов
    static func currentDelegateFor(object: AnyObject) -> AnyObject?
    static func setCurrentDelegate(delegate: AnyObject?, toObject object: AnyObject)
}

class DelegateProxy {
	public class func createProxyForObject(object: AnyObject) -> AnyObject {}
	public class func assignedProxyFor(object: AnyObject) -> AnyObject? {}
	public class func assignProxy(proxy: AnyObject, toObject object: AnyObject) {}
	public func setForwardToDelegate(delegate: AnyObject?, retainDelegate: Bool) {}
	public func forwardToDelegate() -> AnyObject? {}
}

extension UISearchController {
	// создаем обертку над делегатом, создающую наш прокси RxSearchControllerDelegateProxy
    public var rx_delegate: DelegateProxy {
        return proxyForObject(RxSearchControllerDelegateProxy.self, self)
    }
    // Rx обертка над конкретным событием UISearchControllerDelegate.didDismissSearchController(_:)
    public var rx_didDismiss: Observable {
        return rx_delegate
            .observe(#selector(UISearchControllerDelegate.didDismissSearchController(_:)))
            .map {_ in}
    }
    ...
}

public class RxSearchControllerDelegateProxy
    : DelegateProxy
    , DelegateProxyType
    , UISearchControllerDelegate {
    // для проставление делегата (нашего прокси) нам нужно знать тип класса (UISearchController) и имя свойства для делегата (delegate)
    public class func setCurrentDelegate(delegate: AnyObject?, toObject object: AnyObject) {
        let searchController: UISearchController = castOrFatalError(object)
        searchController.delegate = castOptionalOrFatalError(delegate)
    }
    // те же знания необходимы и для того, чтобы вернуть прокси по запросу
    public class func currentDelegateFor(object: AnyObject) -> AnyObject? {
        let searchController: UISearchController = castOrFatalError(object)
        return searchController.delegate
    }
}

proxyForObject(RxSearchControllerDelegateProxy.self, self)

public func proxyForObject(type: P.Type, _ object: AnyObject) -> P {
    MainScheduler.ensureExecutingOnScheduler() // проверяем что код выполняется в главном потоке
    let maybeProxy = P.assignedProxyFor(object) as? P // assignedProxyFor определена в DelegateProxy и больше нигде не переопределяется
    let proxy: P
    if maybeProxy == nil {
        proxy = P.createProxyForObject(object) as! P // создаем прокси (в нашем случае типа RxSearchControllerDelegateProxy). Метод createProxyForObject определен в DelegateProxy и при инициализации просто сохраняет объект для которого является прокси, но его могут переопределять классы с наследованием, для иерархии которых каждому нужен свой делегат
        P.assignProxy(proxy, toObject: object) // прикрепляем новый прокси к объекту. assignProxy так же определен в DelegateProxy, и его не переопределяют, как и assignedProxyFor
        assert(P.assignedProxyFor(object) === proxy)
    }
    else {
        proxy = maybeProxy! // если прокси уже был прикреплен ранее - берем его
    }
    let currentDelegate: AnyObject? = P.currentDelegateFor(object) // возвращает текущий делегат содержащийся в свойстве UI объекта (обычно delegate/dataSource). Все кто реализуют протокол DelegateProxy переопределяют этот метод, т.к. там есть приведение as! к типу объекта к которому мы прикрепляем прокси
    if currentDelegate !== proxy { // если текущий делегат не идентичен текущей прокси
        proxy.setForwardToDelegate(currentDelegate, retainDelegate: false) // проставляем старый делегат в качестве делегата к которому будут пересылаться сообщения. Таким образом у UI объекта будет одновременно и прокси делегат и обычный. Изначальная реализация лежит в Objective-C части Rx, а точнее в _RXDelegateProxy.
        P.setCurrentDelegate(proxy, toObject: object) // все кто соответствует протоколу DelegateProxy переопределяют этот метод, т.к. там есть приведение as! к типу объекта к которому мы прикрепляем прокси
        assert(P.currentDelegateFor(object) === proxy)
        assert(proxy.forwardToDelegate() === currentDelegate)
    }
    return proxy
}

extension UIScrollView {
    /**
    Factory method that enables subclasses to implement their own `rx_delegate`.
    - returns: Instance of delegate proxy that wraps `delegate`.
    */
    public func rx_createDelegateProxy() -> RxScrollViewDelegateProxy {
        return RxScrollViewDelegateProxy(parentObject: self)
    }
    /**
    Reactive wrapper for `delegate`.
    For more information take a look at `DelegateProxyType` protocol documentation.
    */
    public var rx_delegate: DelegateProxy {
        return proxyForObject(RxScrollViewDelegateProxy.self, self)
    }
...
}

public class RxScrollViewDelegateProxy
    : DelegateProxy
    , UIScrollViewDelegate
    , DelegateProxyType {
    public override class func createProxyForObject(object: AnyObject) -> AnyObject {
        let scrollView = (object as! UIScrollView)
        return castOrFatalError(scrollView.rx_createDelegateProxy())
    }
    ...
}

extension UITableView {
    /**
    Factory method that enables subclasses to implement their own `rx_delegate`.
    - returns: Instance of delegate proxy that wraps `delegate`.
    */
    public override func rx_createDelegateProxy() -> RxScrollViewDelegateProxy {
        return RxTableViewDelegateProxy(parentObject: self)
    }
   	...
}

public class RxTableViewDelegateProxy
    : RxScrollViewDelegateProxy
    , UITableViewDelegate {
    public weak private(set) var tableView: UITableView?
    public required init(parentObject: AnyObject) {
        self.tableView = (parentObject as! UITableView)
        super.init(parentObject: parentObject)
    }
}