Android:从 Rx Android 改造中回归

Question

我有一个返回 Observable 的类方法。可观察对象包含传递给 post 方法所需的授权 key 。我能够从一个类返回值，但无法按时在另一类中捕获它。我正在阅读，人们使用了 Observable.blocking.first 来阻止当前线程，这不是一个好方法。任何人都知道如何在另一个类上捕获它。这是我的代码:

返回可观察值的类:

public class GetAuthenticationToken {
     String authentication_token;
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl("https://abc.def.com/")
                .addConverterFactory(ScalarsConverterFactory.create())
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .build();
        GetTokenInterface service = retrofit.create(GetTokenInterface.class);

        Observable<String> response_call = service.getToken1(setAPI_KEY, getaccesstoken);
        String savedToken;
        @CheckResult
        public Observable<String> getToken() {
            return service.getToken1(setAPI_KEY, getaccesstoken)
                    .subscribeOn(Schedulers.newThread())
                    .doOnNext(new Action1<String>() {
                        public void call(String token) {
                            savedToken = token;
                        }
                    }) 
                    .observeOn(AndroidSchedulers.mainThread());
        }

        public String getSavedToken() {
            return savedToken;
        }
}

但不知道在另一个类中准时捕获它而不阻塞线程:

  public class Post_To_Api {
GetAuthenticationToken getauthenticationtoken = new GetAuthenticationToken();
        Observable<String> generated_token = getauthenticationtoken.getToken(); //Dont know to get it here on time without blocking thread
                    generated_token.subscribeOn(Schedulers.newThread())
                            .observeOn(AndroidSchedulers.mainThread()) 
                            .subscribe(new Subscriber<String>() {
                                @Override
                                public void onCompleted() {

                                    System.out.print("Complete");
                                }

                                @Override
                                public void onError(Throwable e) {

                                    System.out.print("Fail");
                                }

                                @Override
                                public void onNext(String token) {
                                    authentication_token = token; //getting correct value here
                                }
                            });

    }

Answer 1

解决方案是保持异步执行操作，而不是使其阻塞。

MyApiServide myApiService = // Create your retrofit API service 

public Observable<SomeApiResult> requestApiItem() { 
    return getApiToken()
       .flatMap(new Func1<String, Observable<SomeApiResult>>() {
           public Observable<SomeApiResult> call(String token) {
               return myApiService.requestItem(token);
           }
       })
       .subscribeOn(Schedulers.io())
}


public Observable<String> getApiToken() {
    // get token from API as you have
}

// Were you use the API
requestApiItem()
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Subscriber<SomeApiResult>() {
        @Override
        public void onCompleted() {
            System.out.print("Complete");
        }

        @Override
        public void onError(Throwable e) {
            System.out.print("Fail");
        }

        @Override
        public void onNext(SomeApiResult apiResult) { 
            myView.setText(apiResult.someValue); // or whatever you want to do with result.
        }
    });