Kode.Java

RxOkhttp.streamLines(client, request)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(response -> {
                    // if response done do next download bla bla bla
                }, throwable -> {
                    // if response failed do try again
                });