antoninbiret / rxeureka Goto Github PK

class ViewController: FormViewController {
  let viewModel: ViewModeling = ViewModel(model: Model(text: "RxEureka", phone: "0000"))
...

    self.model.text
      .asObservable()
      .bind(to: self._textRow.rx.value)
      .disposed(by: self._disposeBag)
    
    self._textRow.rx.value
      .asObservable()
      .bind(to: self.model.text)
      .disposed(by: self._disposeBag)

    self._textRow.rx.value
        .asObservable()
        .bind(to: self.model.text)
        .disposed(by: self._disposeBag)

    self.model.text
      .asObservable()
      .bind(to: self._textRow.rx.value)
      .disposed(by: self._disposeBag)

public var value: ControlProperty<String?> {
	let source = Observable<String?>.create { observer in
		observer.onNext(self.base.value)
		self.base.onChange({ (row) in //<---- this `self.base` reference causes the leak
			observer.onNext(row.value)
		})
		return Disposables.create {
			observer.onCompleted()
		}
	}
	let bindingObserver = BindableObserver(container: self.base) { (row, value) in
		row.value = value
	}
	return ControlProperty(values: source, valueSink: bindingObserver)
}

public var value: ControlProperty<String?> {
	let source = Observable<String?>.create { observer in
		var base: Base? = self.base

		observer.onNext(base?.value)
		base?.onChange({ (row) in
			observer.onNext(row.value)
		})
		return Disposables.create {
			base = nil
			observer.onCompleted()
		}
	}
	let bindingObserver = BindableObserver(container: self.base) { (row, value) in
		row.value = value
	}
	return ControlProperty(values: source, valueSink: bindingObserver)
}

public var value: ControlProperty<Double?> {
	var base: Base? = self.base
	
	let source = Observable<Double?>.create { observer in
		base?.onChange { row in
			observer.onNext(row.value)
		}
		return Disposables.create {
			base = nil
			observer.onCompleted()
		}
	}
	let bindingObserver = BindableObserver(container: self.base) { (row, value) in
		row.value = value
	}
	return ControlProperty(values: source, valueSink: bindingObserver)
}

    self._configureBindings()

    DispatchQueue.main.asyncAfter(deadline: .now() + 3.0, execute: {
        print("trigger")
        self.model.text = Variable("testing...")
        for row in self.form.rows {
            row.updateCell()
        }
    })

row.onCellHighlightChanged { _, row in
    guard false == row.isHighlighted, row.wasChanged else { return }
    //the user has finished editing and the row was changed
}

public var isHighlighted: ControlProperty<Bool> {
	var base: Base? = self.base
	
	let source = Observable<Bool>.create { observer in
		observer.onNext(base?.isHighlighted ?? false)
		
		base?.onCellHighlightChanged{ _, row in
			observer.onNext(row.isHighlighted)
		}
		return Disposables.create {
			base = nil
			observer.onCompleted()
		}
	}
	let bindingObserver = BindableObserver(container: self.base) { (row, value) in
		row.isHighlighted = value
	}
	return ControlProperty(values: source, valueSink: bindingObserver)
}

Observable.combineLatest(
    row.rx.isHighlighted,
    row.rx.value
){ (isHighlighted: $0, value: $1) }
.subscribe(onNext: { isHighlighted, value in
   //`isHighlighted == false` indicates that the user did end editing
   //`value` contains the latest value
}).dispose(by: disposeBag)

Targ|feature/eureka_try⚡ ⇒ carthage update
*** Fetching RxEureka
*** Checking out RxEureka at "0.2.1"
*** xcodebuild output can be found in /var/folders/hr/pwfk8qcn2lz77z5bwjrzshmc0000gn/T/carthage-xcodebuild.hnhRaN.log
*** Skipped building RxEureka due to the error:
Dependency "RxEureka" has no shared framework schemes

If you believe this to be an error, please file an issue with the maintainers at https://github.com/antoninbiret/RxEureka/issues/new

// Bind viewModel Variable to --> row UI
self.viewModel.quantityRxString
    .asObservable()
    .bind(to: quantityRow?.cell.stepper.rx.value)
    .disposed(by: self.disposeBag)

private func configureBindings() {

    // Bind 'email' row to variable
    self.emailRow!.rx.value
        .asObservable()
        .bind(to: self.viewModel.usernameText)
        .disposed(by: self.disposeBag)

    // Bind variable to 'email' row
    self.viewModel.usernameText
        .asObservable()
        .bind(to: self.emailRow!.rx.value)
        .disposed(by: self.disposeBag)

    self.viewModel.usernameText
        .asObservable()
        .subscribe(onNext: { value in
            print("self.viewModel.usernameText did change to \(String(describing: value))")
        })
        .disposed(by: self.disposeBag)