Observable.fromCallable { println("${System.currentTimeMillis()}") }
                .subscribeOn(Schedulers.computation())
                .delay(10, TimeUnit.SECONDS)
                .map { "loading ${System.currentTimeMillis()}" }
                .doOnNext { r.accept(it) }
                .doOnNext { r1.accept(it) }
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeBy(
                        onNext = { println("save data $it") },
                        onError = { throw it })

        val click = RxView.clicks(test).map { "click ${System.currentTimeMillis()}" }
        val click1 = RxView.clicks(test1).map { "click ${System.currentTimeMillis()}" }
        r.zipWith(click)
                .subscribeBy(
                        onNext = { println("use data $it") },
                        onError = { throw it }
                )
        r1.zipWith(click1)
                .subscribeBy(
                        onNext = { println("use data 1 $it") },
                        onError = { throw it }
                )