我想通过订阅一个 Observable 来填充抽屉导航，它从数据库获取数据，完成后通知订阅者(使用 RxJava)。我做了类似的事情，Subscriber 是一个扩展 Fragment 的类，但不同之处在于 Navigation Drawer 不是一个单独的 fragment ，而是被定义的在主要 Activity 中。

如何将 Navigation Drawer 订阅到 Observable？

主 Activity .java

private DrawerLayout mDrawerLayout;
private ListView mDrawerList;

@Override
public void onStart() {                                                                                                                       mLoadAndStoreDataObservable = Observable.create(
    super.onStart();                                                                                                                              new Observable.OnSubscribe<String>() {

    // fragment creation code was here

    // populates a String[] myStringArray for Navigation Drawer                                                                                                                                                                  permitsSQLiteManager.addLogLine(mActivity, logString);
    if (!skipRestfulServiceCall) {
        getDataFromRestfulService();                                                                                                                      }
    }                                                                                                                                                     catch (Exception e) {
    else {  // get data from SQLite                                                                                                                           Log.e("loadAndStoreData  ", "Exception: " + e.getMessage());
        getDataFromSQLite();                                                                                                                                  mProgressDialog.dismiss();
    }                                                                                                                                                     }
                                                                                                                                                      }
    mTitle = mDrawerTitle = getTitle();                                                                                                           }
    mDrawerLayout = (DrawerLayout) findViewById(R.id.drawer_layout);                                                                              .subscribeOn(Schedulers.io())
    mDrawerList = (ListView) findViewById(R.id.left_drawer);                                                                                      .observeOn(AndroidSchedulers.mainThread())
                                                                                                                                                  .subscribe(mDrawerLayout); // parameter was a Fragment
    mDrawerLayout.setDrawerShadow(R.drawable.drawer_shadow, GravityCompat.START);

    mDrawerList.setAdapter(new ArrayAdapter<String>(this,  R.layout.drawer_list_item, myStringArray));
    mDrawerList.setOnItemClickListener(new DrawerItemClickListener());

    // enable ActionBar app icon to behave as action to toggle nav drawer
    getActionBar().setDisplayHomeAsUpEnabled(true);
    getActionBar().setHomeButtonEnabled(true);

    mDrawerToggle = new ActionBarDrawerToggle(this,mDrawerLayout, R.drawable.ic_drawer, R.string.drawer_open,R.string.drawer_close
    ) {
        public void onDrawerClosed(View view) {
            getActionBar().setTitle(mTitle);
            invalidateOptionsMenu(); // creates call to onPrepareOptionsMenu()
        }

        public void onDrawerOpened(View drawerView) {
            getActionBar().setTitle(mDrawerTitle);
            invalidateOptionsMenu(); // creates call to onPrepareOptionsMenu()
        }
    };
    mDrawerLayout.setDrawerListener(mDrawerToggle);
}

private void getDataFromRestfulService() {

    <get data>


    // implement RxJava-Observable/Subscriber
    mLoadAndStoreDataObservable = Observable.create(
            new Observable.OnSubscribe<String>() {
                @Override
                public void call(Subscriber<? super String> subscriber) {

                    try {
                        Utilities.loadAndStoreData(mActivity);
                        subscriber.onNext("Utilities.loadAndStoreData Done");
                        //subscriber.onCompleted();
                        Log.e("MainActivity.onCreate()", "subscriber.onNext(\"Utilities.loadAndStoreData Done\")");

                        String logString = "MainActivity.onCreate() - subscriber.onNext(Utilities.loadAndStoreData Done)";
                        Log.e(TAG, logString);
                        PermitsSQLiteManager permitsSQLiteManager = PermitsSQLiteManager.getInstance();
                        permitsSQLiteManager.addLogLine(mActivity, logString);

                        mProgressDialog.dismiss();
                    }
                    catch (Exception e) {
                        Log.e("loadAndStoreData  ", "Exception: " + e.getMessage());
                        subscriber.onError(e);
                        mProgressDialog.dismiss();
                    }
                }
            }
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(mDrawerLayout); // compile error // suscriber was a Fragment, but no longer
}

最佳答案

如果 mDrawerLayout 是实现 Observer 的类的实例，那么您可以将其转换为 Observer

NavigationDrawer mDrawerLayout = ...
yourObservable.subscribe((Observer)mDrawerLayout);

如果它没有实现Observer 接口(interface)，那么您可以创建一个新的Observer 来操纵您的抽屉导航。 (您可能需要将 mDrawerLayout 声明为 final)

final NavigationDrawer  mDrawerLayout = ...
yourObservable.subscribe(new Observer<String>() {
                @Override
                public void onCompleted() {
                    // on completed
                }

                @Override
                public void onError(Throwable throwable) {
                    // on error
                }

                @Override
                public void onNext(String people) {
                        mDrawerLayout.doSomething(); 
                }
            });

关于android - 将抽屉导航订阅到 Observable，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31279443/