android.support.annotation.RestrictTo#com.squareup.otto.Bus源码实例Demo

public static void update(final Team team, final Bus bus) {
    Observable.create(new Observable.OnSubscribe<Object>() {
        @Override
        public void call(Subscriber<? super Object> subscriber) {
            if (BizLogic.isCurrentTeam(team.get_id())) {
                MainApp.PREF_UTIL.putObject(Constant.TEAM, team);
                subscriber.onNext(null);
            }
        }
    }).subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Action1<Object>() {
                @Override
                public void call(Object o) {
                    bus.post(new UpdateTeamEvent());
                }
            });

}
 

public void update(Bus bus) {
    if (preference == null) {
        User user = (User) MainApp.PREF_UTIL.getObject(Constant.USER, User.class);
        if (user != null) {
            setPreference(user.getPreference());
        }
    }
    MainApp.PREF_UTIL.putObject(Constant.USER, this);
    bus.post(new UpdateUserEvent());
}
 

public MoviesListPresenterImp(UpcomingMoviesApi upcomingMoviesApi, Bus bus,
    Comparator<Movie> movieDateComparator, Comparator<Movie> movieTitleComparator) {
  this.upcomingMoviesApi = upcomingMoviesApi;
  this.bus = bus;
  this.movieDateComparator = movieDateComparator;
  this.movieTitleComparator = movieTitleComparator;
}
 

@Override public void onCreate() {
  super.onCreate();

  eventsPort = new OttoEventsAdapter(new Bus());
  StoragePort storagePort = new SDCardStorageAdapter(eventsPort);
  FoldersModule notesModule = new FoldersModule(storagePort, eventsPort);

  notesModule.run();
}
 

private void flushApiEventQueue(boolean loadCachedData) {
    Bus bus = getBus();
    boolean isQueueEmpty;
    while (! mApiEventQueue.isEmpty()) {
        ApiCallEvent event = mApiEventQueue.remove();
        isQueueEmpty = mApiEventQueue.isEmpty();
        if (loadCachedData) event.loadCachedData();
        bus.post(event);
        if (isQueueEmpty) {     // don't retry, gets into infinite loop
            mApiEventQueue.clear();
        }
    }
}
 

public static void init(Context context){
    //TODO initialize singletons or global instance of class
    Configuration config = new Configuration.Builder(context)
            .injector((WatchMeApplication) context)
            .build();

    sJobManager = new JobManager(context, config);

    sOkHttpClient = new OkHttpClient();
    sOkClient = new OkClient(sOkHttpClient);

    sEventBus = new Bus();
}
 

@Provides
@Singleton
MoviesListPresenter providesMoviesListPresenter(UpcomingMoviesApi upcomingMoviesApi, Bus eventBus,
    @Named("date") Comparator<Movie> movieDateComparator,
    @Named("title") Comparator<Movie> movieTitleComparator) {
  return new MoviesListPresenterImp(upcomingMoviesApi, eventBus, movieDateComparator,
      movieTitleComparator);
}
 

@Inject
public MoviesPresenter(ConfigurationUsecase configurationUsecase, GetMoviesUsecase getMoviesUsecase, Bus bus) {

    mConfigureUsecase   = configurationUsecase;
    mGetPopularShows    = getMoviesUsecase;
    mBus = bus;
}
 

public GetMovieDetailUsecaseController(String movieId, Bus uiBus,
    MediaDataSource dataSource) {

    mMovieId        = movieId;
    mUiBus          = uiBus;
    mMovieDataSource= dataSource;

    mUiBus.register(this);
}
 

@Inject
public MainPresenter(UserStorage mUserStorage, UserDao mUserDao, Bus mBus,
                     Observable<Integer> mNotificationObservable, UpdateAgent mUpdateAgent, Context mContext) {
    this.mUserStorage = mUserStorage;
    this.mUserDao = mUserDao;
    this.mBus = mBus;
    this.mNotificationObservable = mNotificationObservable;
    this.mUpdateAgent = mUpdateAgent;
    this.mContext = mContext;
}
 

@Inject
public LoginPresenter(GameApi gameApi, Bus bus, UserDao userDao, UserStorage userStorage) {
    mGameApi = gameApi;
    mBus = bus;
    mUserDao = userDao;
    mUserStorage = userStorage;
}
 

@Inject
public ContentPresenter(ForumApi forumApi, Context context, UserStorage userStorage, Bus mBus) {
    mForumApi = forumApi;
    mContext = context;
    mUserStorage = userStorage;
    this.mBus = mBus;
}
 

@Inject
public ContentPagerPresenter(ContentRepository mContentRepository, ForumApi mForumApi, Bus mBus,
                             ImageCacheDao mImageCacheDao, OkHttpHelper mOkHttpHelper, UserStorage mUserStorage) {
    this.mContentRepository = mContentRepository;
    this.mForumApi = mForumApi;
    this.mBus = mBus;
    this.mImageCacheDao = mImageCacheDao;
    this.mOkHttpHelper = mOkHttpHelper;
    this.mUserStorage = mUserStorage;
}
 

@Inject
public AccountPresenter(UserDao mUserDao, Activity mActivity, UserStorage mUserStorage,
                        Bus mBus) {
    this.mUserDao = mUserDao;
    this.mActivity = mActivity;
    this.mUserStorage = mUserStorage;
    this.mBus = mBus;
}
 

static void initialize(Context context, String uuid, String username) {
    instance = new BridgefyListener(context, new Bus());
    instance.setmPlayer(new Player(uuid, username));
}
 

/**
 *      GETTERS
 */

static Bus getOttoBus() {
    return instance.ottoBus;
}
 

public Bus getBus() {
    return this.eventBus;
}
 

public static Bus getInstance() {
    return BUS;
}
 

public Bus getEventBus(){
    return mEventBus;
}
 

public static Bus get() {
    return bus;
}
 

@Provides
@Singleton
public Bus provideBus(GithubApi authApi) {
	return new Bus();
}
 

@Override
public Bus getBus() {
	return null;
}
 

public void setEventBus(Bus bus) {
    mEventBus = bus;
}
 

public Bus getProvider() {
    return bus;
}
 

public OttoEventsAdapter(Bus bus) {
  this.bus = bus;
}
 

@Inject
public EventPosterHelper(Bus bus) {
  mBus = bus;
}
 

public Bus getBus() {
  return mBus;
}
 

public static Bus getBus() {
    return BUS;
}
 

@Provides
@Singleton
public Bus provideBusEvent() {
  return new Bus();
}
 

@Provides
@Singleton
Bus provideEventBus() {
    return new Bus();
}