想要返回值并处理订单有问题

Question

我需要从类B中的方法C返回一个值。

我希望我的代码像这样处理：1 - 2 - 3 - 4 - 5

但它的处理方式是：1-4-5-2-3

（如您所见，我在代码中添加了一些日志。）

我已经处理这个问题一个多星期了，但我找不到问题。

我在这个问题中删除了一些无用的代码。

问题是什么？我如何解决这个问题？

我重写了这篇文章，因为有人说我把代码缩短得太多了。

希望足够了！

提前谢谢你！

Class A
public class a() {
    public void checkConnectivity(Context context) {
         this.context = context;
         myObservable.subscribe(mySubscriber);
    }

    private Observable<Integer> myObservable = Observable.create(
        new Observable.OnSubscribe<Integer>() {
            @Override
            public void call(Subscriber<? super Integer> sub) {
                Log.d("1", "1");
                int connType = cc.getConnectionStatus(context);
                sub.onNext(connType);
                sub.onCompleted();
            }
        }
    );

    private Subscriber<Integer> mySubscriber = new Subscriber<Integer>() {
        @Override
        public void onNext(Integer connType) {
            int code = c.getcode();
            Log.d("4", "4");
            textView.setText("code : " + code);
        }

        @Override
        public void onCompleted() {
            Log.d("5", "5");
        }

        @Override
        public void onError(Throwable e) {
            Log.d("-- NetPresenter", "onError");
        }
    };
}

Class C
public class C() {
    public int getcode() {
         observable
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<Response<ResponseBody>>() {
                public void onCompleted() {
                    Log.d("3", "3");
                }

                public void onError(Throwable e) {
                    code = 0;
                }

                public void onNext(Response<ResponseBody> response) {
                    code = 1;
                    Log.d("2", "2");
                }
            });
        return code;
    }
}

Answer 1

首先，如果没有其他指定，RxJava在默认情况下是同步的。这两条线

.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())

使您的c.getcode（）调用异步。如果你去掉这些线，你就会得到你所需要的。我自己检查过了。

P、 请注意，文本视图。setText（“代码：”代码） 可能引发异常（如果您不是从UI线程启动整个链）。因此，您需要找到在UI线程中运行此代码的变通方法（带有Looper.getMainLooper（）的处理程序可能会有所帮助）。

Upd 1。尝试postById。execute（）在同一线程中运行请求。只有在同一线程中进行所有调用，才能实现目标<代码>postById。排队初始化异步调用。所以你又把它弄坏了。