Android:Returning 来自 Rx Android 改造

Question

我有一个 class 方法是 returning Observable。 observable 包含传递给 post 方法所需的授权密钥。我能够从一个 class 中获取 return 值，但无法按时在另一个 class 中捕获它。我正在阅读，人们使用 Observable.blocking.first 阻塞当前线程，这不是一个好方法。任何人都知道如何在另一个 class 中捕获它。这是我的代码：

Class return 可观察到：

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;
        }
}

但不知道在不阻塞线程的情况下在另一个 class 中准时捕获它：

  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.
        }
    });

Android:Returning 来自 Rx Android 改造

Android:Returning from Rx Android Retrofit

android

retrofit

rx-android

retrofit2