rx.Observable.create((Subscriber<? super InitResualt> subscriber)->{

            //опрос сервера


            })  .retry()
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe((t)->{
                    Log.d(GV.LOG_TITLE,"Next");
                },(t)->{
                    Log.d(GV.LOG_TITLE,"Error");

                },()->{

                    this.showMessege("bla bla bla");

                });