EventBus 为单个 post 调用两个不同的处理程序

EventBus calling two different handlers for a single post

我在使用 EventBus 3.0.0 时遇到问题,我 post 像这样的单个事件:

Call<List<SessionSpec>> call = httpService.getSessionSpecs();
call.enqueue(new Callback<List<SessionSpec>>() {

   @Override
   public void onResponse(Call<List<SessionSpec>> call, Response<List<SessionSpec>> response)  {
       if (response.isSuccessful())  {
           List<SessionSpec> specs = response.body();
           EventBus.getDefault().post((List<SessionSpec>)specs);
       }
       else Log.e(TAG, "sendSessionSpecs(): request NOT successful");
   }

   @Override
   public void onFailure(Call<List<SessionSpec>> call, Throwable t)  {
      Log.e(TAG, "sendSessionsSpecs(): failed");
   }
});

我在同一个片段中有两个订阅者,每个订阅者都有不同的签名,但他们都是从一个 post:

@Subscribe
public void onSessionSpec(List<SessionSpec> specs) {
    Log.d(TAG, "onSessionSpec(): entered");
    Log.d(TAG, "    : number of session specs: " + specs.size());
}

第二个订阅者定义为:

@Subscribe
public void onOverlayType(List<OverlayType> types) {
    Log.d(TAG, "onOverlayType(): entered");
    Log.d(TAG, "    : number of overlay types: " + types.size());
}

这两个回调都在一个片段中,该片段在 post 完成时处于活动状态,并且我已验证 post 仅被调用一次。当单个 SessionSpec 事件被 posted 时,onSessionSpec 和 onOverlayType 回调均由事件类型为 List> 的 EventBus 调度,因此 onOverlayType 回调在其回调参数中接收到错误的类型。 class OverlayType 是一个简单的 POJO class,有 2 个成员,一个 int "sid" 和一个 String "name"。 class SessionSpec 更复杂;它确实有一个成员 String "name" 但除此之外,这两个 class 之间没有其他共同点。我已验证 SessionSpec class.

中没有与 "OverlayType" 非常相似的内容

接口定义是这样的:

public interface VcapHttpInterface {

    @GET("overlay/types")
    Call<List<OverlayType>> getOverlayTypes();

    @GET("session/list")
    Call<List<SessionSpec>> getSessionSpecs();

    @GET("session/{id}")
    Call<Session> getSession(@Path("id") int sid);

}

getSession事件post/callback没有问题。

我花了一整天的时间试图找出问题所在,所以我现在一无所知。有人知道我的代码可能有什么问题吗?

谢谢, -安德烈斯

编辑:EventBus 如何知道为特定响应调用哪个处理程序?我读过的一些 post 说 EventBus 不使用处理程序签名,但它怎么知道如何将响应映射到正确的订阅处理程序例程?有没有办法明确定义给定事件的处理程序回调?

EventBus 检查您正在 posting 的对象的 class,并调用在其参数中期望 class 的方法。在您的情况下,您正在 posting 一个 List 的对象。在您的两个听众中,您都希望有一个 List 类型的对象。无论您在 OverlayTypeSessionSpec 中放入什么泛型,eventbus 都会调用两者。为了使其工作,您必须将模型定义为事件。

public class OverlayTypeEvent {

    public List<OverlayType> types;

    public OverlayTypeEvent(List<OverlayType> types) {
        this.types = types;
    }
}

public class SessionSpecEvent {

    public List<SessionSpec> types;

    public SessionSpecEvent(List<SessionSpec> types) {
        this.types = types;
    }
}

并单独收听它们。然后 post 个具有特定类型的事件。

@Subscribe
public void onSessionSpec(OverlayTypeEvent event) {
    List<OverlayType> overlayTypes = event.overlayType;
}

如果您不想在每次发送列表数据时都创建新的 class 作为容器,您可以 Pair 作为简单的容器,它有两个通用字段 (firstsecond) 包含变量。

你可以使用first作为key来检查class的类型,second包含实际数据。

List<SessionSpec> specs = response.body();
EventBus.getDefault().post(new Pair<>(SessionSpec.class.getSimpleName(), specs));

接收数据:

@Subscribe
public void onSessionSpec(Pair<String, List<SessionSpec>> specContainer){
    if (SessionSpec.class.getSimpleName().equals(specContainer.first)) {
        List<SessionSpec> sessionSpecs = specContainer.second;
    }
}

@Subscribe
public void onOverlayType(Pair<String, List<OverlayType>> overlayContainer) {
    if (OverlayType.class.getSimpleName().equals(overlayContainer.first)) {
        List<OverlayType> overlayTypes = overlayContainer.second;
    }
}

此解决方案的优点:减少创建不需要的 classes。
缺点onSessionSpeconOverlayType 接到电话。