rxjava

code.java

 Observable.just("")
                .subscribeOn(Schedulers.immediate()).observeOn(Schedulers.io()).doOnSubscribe(() -> {
            //tv1.setText("fe");
        })
                .map(x -> {
                    InitVo initVo = qrHttp.init();

                    return initVo;
                })
                .map(initVo -> {
                            LoginResponse loginResponse = qrHttp.login("admin", "admin", initVo);
                            return loginResponse;
                        }
                )
                .map(loginResponseVo -> {
                    QuesyResponse quesyResponse = qrHttp.query("", loginResponseVo.getLoginCookies());
                    return quesyResponse;
                }).subscribe(new Subscriber<QuesyResponse>() {
            @Override
            public void onCompleted() {
                Looper.prepare();
                Toast.makeText(context, "onCompleted", Toast.LENGTH_SHORT).show();
                Looper.loop();
            }

            @Override
            public void onError(Throwable e) {
                Looper.prepare();
                e.printStackTrace();
                Toast.makeText(context, "e:" + e.getCause(), Toast.LENGTH_SHORT).show();
                Looper.loop();
            }

            @Override
            public void onNext(QuesyResponse quesyResponse) {

                Looper.prepare();
                Toast.makeText(context, "msg:" + quesyResponse.getMsg(), Toast.LENGTH_SHORT).show();
                Looper.loop();

            }
        });