1

我正在尝试将所有 UI 事件合并到一个 Observable 中，这样我就可以对所有事件做出反应，例如：onCreate 生命周期、RecyclerView 中的滚动事件、搜索视图中的 searchEvents 和动作模式激活中的 deleteEvents。我正在使用 Rxbinding 来实现这一点。我正在尝试从 Jake Wharton 的演示文稿中实现 Redux 模式：http: //jakewharton.com/the-state-of-managing-state-with-rxjava/

实际结果：只有 GetUsersEvent 被触发，而其他事件没有。

预期结果：所有事件都会在适当的时候触发。

提前致谢。我的代码：

public Observable events; 

@Override
public void onCreate(Bundle savedInstanceState) {
    events = Observable.just(new GetUsersEvent());
    //... boiler plate
    events.mergeWith(RxRecyclerView.scrollEvents(userRecycler).map(recyclerViewScrollEvent -> {
        int totalItemCount = layoutManager.getItemCount();
        int firstVisibleItemPosition = layoutManager.findFirstVisibleItemPosition();
        if ((layoutManager.getChildCount() + firstVisibleItemPosition) >= totalItemCount
                && firstVisibleItemPosition >= 0 && totalItemCount >= PAGE_SIZE) {
            uiModel = new UserListState.Builder(uiModel)
                    .setUsers(uiModel.getUsers())
                    .setYScroll(firstVisibleItemPosition)
                    .build();
            return new UsersNextPageEvent(uiModel.getLastId());
        }
        return null;
    }));
}

@Override
public boolean onCreateActionMode(ActionMode mode, Menu menu) {
    mode.getMenuInflater().inflate(R.menu.selected_list_menu, menu);
    events.mergeWith(RxMenuItem.clicks(menu.findItem(R.id.delete_item))
            .map(click -> new DeleteUsersEvent(usersAdapter.getSelectedItemsIds())));
    return true;
}

@Override
public boolean onCreateOptionsMenu(Menu menu) {
    getMenuInflater().inflate(R.menu.list_menu, menu);
    SearchManager searchManager = (SearchManager) getSystemService(Context.SEARCH_SERVICE);
    SearchView mSearchView = (SearchView) menu.findItem(R.id.menu_search).getActionView();
    mSearchView.setSearchableInfo(searchManager.getSearchableInfo(getComponentName()));
    events.mergeWith(RxSearchView.queryTextChanges(mSearchView)
            .map(query -> new SearchUsersEvent(query.toString()))
            .doOnNext(searchUsersEvent -> Log.d("searchEvent", "eventFired")));
    return super.onCreateOptionsMenu(menu);
}

@Override
public void onResume() {
    super.onResume();
    events.compose(userListVM.uiModels(mapEventsToActions, mapActionsToExecutables, stateReducer,
            DeleteUsersEvent.class, GetUsersEvent.class, SearchUsersEvent.class, UsersNextPageEvent.class))
            .compose(bindToLifecycle()).subscribe(new BaseSubscriber<>(this, ERROR_WITH_RETRY));
}
4

1 回答 1

1

好吧，你有很多events.mergeWith(...)，但是你对结果做了什么？该操作为您提供了一个新的 observable。

你可以做events = events.mergeWith(...)。

于 2017-04-21T21:13:26.623 回答