Kotlin-FrpStudy

map (Sodium) -> RxKotlin. Learn with a Book: "Reactive Functional Programming".

    override fun onViewCreated(v: View, savedInstanceState: Bundle?) {
       super.onViewCreated(v, savedInstanceState)
       
       /** frp spinner **/
       
       val value = BehaviorSubject.create<Int>().apply {
           this.map { i -> i.string }.subscribe(text_output.text())
       }
       val sPlusDelta  = button_plus.clicks().map { 1 }
       val sMinusDelta = button_minus.clicks().map { -1 }
       val sDelta = sPlusDelta.mergeWith(sMinusDelta)
       val sUpdate = sDelta.withLatestFrom(value,
               { delta, value_ -> delta + value_ })
       value.loop(sUpdate.hold(0))
       
   }