Android Retrofit:onNext 其他类需要的值

debugcn 发表于 Dev

开发商

我正在使用带有 Rx java 的 Retrofit 并且我在 onNext 中获取身份验证令牌的值。根据 onNext 的结果，我必须通过在自定义标头中添加令牌来将数据发布到服务器。我是否应该在 on next 中编写所有代码，是否可以从 onNext 返回一个值，以便何时值可用？

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

                Observable<String> response_call = service.getToken1(setAPI_KEY, setaccesstoken);

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

}

然后在另一个班级：

generated_token = getToken();

但我得到了 generate_token null 因为值不可用有没有办法在其中获取值？我必须使用这个值来发布或者我需要在 onNext() 中结合 post observable 吗？

cyroxis

RxJava 代码是异步执行的。例如

public class Foo {

    String value = "a";

    public String getFoo() {
        value = "a"; // This executes first
        Observable.just(value + "a")
                .observeOn(Schedulers.io())
                .subscribe(new Action1<String>() {
                    public void call(String v) {
                        value = v; // This is called later on IO thread.
                    }
                }); // This creates the observable and schedules execution on IO thread.
        return value; // Return value "a"
    }
}

Foo foo = new Foo();
foo.getFoo(); // Return a
Thread.sleep(100);
foo.getFoo(); // likley Return `aa` (depends upon how long the IO thread take to run)
Thread.sleep(100);
foo,getFoo(); // likley Return `aaa` (depends upon how long the IO thread take to run)

如果你想从你的方法 getToken 中获取一个值，你可以返回，Observable<String>如果你想你也可以将令牌保存在你的类中，如下所示。

public class TokenService {

    Retrofit retrofit = new Retrofit.Builder()
            .baseUrl("https://abc.efg.com/")
            .addConverterFactory(ScalarsConverterFactory.create())
            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
            .build();
    GetTokenInterface service = retrofit.create(GetTokenInterface.class); // This should be done outside of the method for performance

    String savedToken;

    public Observable<String> refreshToken() {
        return service.getToken1(setAPI_KEY, setaccesstoken)
                .subscribeOn(Schedulers.newThread())
                .doOnNext(new Action1<String() {
                    public void call(String token) {
                        savedToken = token;
                    }
                }) // Do want is needed with token
                .observeOn(AndroidSchedulers.mainThread());
    }

    public String getSavedToken() {
        return savedToken;
    }

}

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。