BusProvider 未返回 @Subscribe

Question

我在 Android 上使用 BusProvider 来处理执行 AsynTask 后返回到主线程的回传。当 Async 任务完成并成功时，它会注册 Post 并返回到 MAIN 线程以显示警报对话框。但是，当它失败时，我希望它返回到主线程中的相同方法并显示一条关于失败原因的消息。在这种情况下，它正在注册，所以它可以像“此电子邮件已被使用”一样简单。

这似乎对我不起作用，它永远不会回到主线程。

在我使用 BusProvider 的异步任务中，我将在失败时发回此消息：

 @Override
        public void failure(RetrofitError error) {
            BusProvider.getInstance().post(new SignupTask.ErrorEvent(new String(((TypedByteArray) error.getResponse().getBody()).getBytes())));
        }

然后将其传递到ErrorEvent类中：

public class ErrorEvent {

    public String message;

    public ErrorEvent(String message) {
        this.message = ResponseParser(message);
    }

    public String ResponseParser(String response){
        //Handle JSON parsing here of response, need message + the array stack to display to the user what is exactly wrong
        return response;
    }

}

还有一些工作要做，但在我解析信息之前，我想暂时将响应传回。

响应不为空，我在调试时检查了这一点。一旦它返回到 BusProvider.getInstance().post(...) 它就永远不会返回到主线程并点击我的@Subscribe

@订阅：

@Subscribe
public void onSignUpSuccess(SignupResponse event) {
    loading.dismiss();

    if(!BuildConfig.DEBUG_MODE) {
        Log.i(TAG, "!BuildConfig.DEBUG_MODE : " + AnswersAnalytics.SIGN_UP_PATIENT);
        Answers.getInstance().logCustom(new CustomEvent(AnswersAnalytics.SIGN_UP));
    }
    AlertDialog alertDialog = new AlertDialog.Builder(SignupActivity.this).create();
    alertDialog.setTitle("Thank you");
    alertDialog.setMessage(event.getMsg());
    alertDialog.setButton(AlertDialog.BUTTON_NEUTRAL, "OK",
            new DialogInterface.OnClickListener() {
                public void onClick(DialogInterface dialog, int which) {
                    dialog.dismiss();
                    killSignup();
                }
            });
    alertDialog.show();
}

我想使用同样的@Subscribe 来处理错误并显示它。

非常感谢任何帮助！

Answer 1

您不能将事件从另一个线程发布到 UI 线程。您可以为此使用Handler。

private Handler mHandler = new Handler(Looper.getMainLooper()) {
    @Override
    public void handleMessage(Message msg) {
        synchronized (this) {
            BusProvider.get().post(msg.obj);
        }
    }
};

private void post(Object message) {
    Message msg = mHandler.obtainMessage(0);
    msg.obj = message;
    mHandler.sendMessage(msg);
}

@Override
public void failure(RetrofitError error) {
    this.post(new SignupTask.ErrorEvent(new String(((TypedByteArray) error.getResponse().getBody()).getBytes())));
}