override fun execute(): Observable<PartialState> {
   return service.get()
        .onBackground()
        .toObservable()
        .map { price -> ModifyBTCPrice(price[“USD”]?.toFloat()) as PartialState }
        .startWith(ModifyLoading(true) as PartialState)
        .doOnError { e -> println(“Ouuu yeah!!…”)) }
        .doOnNext { logger.log("=> GePrice") }
    }
 }

  
  fun getDispatch(action: Action) {
    inPipeline.onNext(action)
  }
  
  fun changes() = outPipeline.hide()
  
  private fun mainPipe() {
    disposable = inPipeline
      .switchMap { it.execute() }
      .scan(state) { state, action -> Reducer.reduce(state, action) }
      .distinctUntilChanged()
      .doOnNext {
        logger.log(it.toString())
      }
      .subscribeOn(ioScheduler)
      .observeOn(uiScheduler)
      .subscribe { outPipeline.onNext(it) }
  }

object Reducer {
 
 fun reduce(state: State, partialState: PartialState): State =
    when (partialState) {
      is ModifyBTCPrice -> {
        state.copy(btcCurrentPrice = partialState.price, loading = false)
      }
      is ModifyLoading -> {
        state.copy(loading = partialState.value)
      }
      is ModifyBalance -> {
        state.copy(result = (state.btcCurrentPrice * partialState.balance))
      }
      is ModifyError -> {
        state.copy(error = partialState.error, loading = false)
      }
    }
}

store.getDispatch(
   GetBTCPrice(Service())
)

disposable = store.changes().subscribe { render(it) }