java类rx.subscriptions.CompositeSubscription的实例源码

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_profile);

    mSubscriptions = new CompositeSubscription();

    mTvName = (TextView) findViewById(R.id.tv_name);
    mTvEmail = (TextView) findViewById(R.id.tv_email);
    mTvDate = (TextView) findViewById(R.id.tv_date);

    initSharedPreferences();
    loadProfile();
}

public CompositeSubscription getCompositeSubscription() {
    if (this.compositeSubscription == null) {
        this.compositeSubscription = new CompositeSubscription();
    }

    return this.compositeSubscription;
}

public ScheduledAction scheduleActual(Action0 action, long delayTime, TimeUnit unit, CompositeSubscription parent) {
    Future f;
    ScheduledAction run = new ScheduledAction(this.schedulersHook.onSchedule(action), parent);
    parent.add(run);
    if (delayTime <= 0) {
        f = this.executor.submit(run);
    } else {
        f = this.executor.schedule(run, delayTime, unit);
    }
    run.add(f);
    return run;
}

/**
 * 保存订阅后的subscription
 *
 * @param o
 * @param subscription
 */
public void addSubscription(Object o, Subscription subscription) {
    if (mSubscriptionMap == null) {
        mSubscriptionMap = new HashMap<>();
    }
    String key = o.getClass().getName();
    if (mSubscriptionMap.get(key) != null) {
        mSubscriptionMap.get(key).add(subscription);
    } else {
        CompositeSubscription compositeSubscription = new CompositeSubscription();
        compositeSubscription.add(subscription);
        mSubscriptionMap.put(key, compositeSubscription);
    }
}

@Nullable
@Override
public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) {

    View view = inflater.inflate(R.layout.dialog_change_password,container,false);
    mSubscriptions = new CompositeSubscription();
    getData();
    initViews(view);
    return view;
}

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_profile);
    mSubscriptions = new CompositeSubscription();
    initViews();
    initSharedPreferences();
    loadProfile();
}

public void onCreate(DetailView view, App app) {
  this.view = ensureNotNull(view);
  this.app = ensureNotNull(app);
  this.subscriptions = new CompositeSubscription();

  fetchAppUpdates();
  fetchLibraries();
  fetchAnalysisUpdates();
}

public void onCreate(LibraryListView view, Library.Type type) {
  this.view = ensureNotNull(view, "must provide view for presenter");
  this.type = ensureNotNull(type, "must provide type of libraries to load");
  this.subscriptions = new CompositeSubscription();

  fetchFilterPreference();
  loadLibraries();
}

public void onCreate(LibraryDetailView view, Library library) {
  this.view = view;
  this.library = library;
  this.subscriptions = new CompositeSubscription();

  initUi();
  loadApps();
}

@Override
public void onCreate(@Nullable Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    MainApplication app = (MainApplication) getContext().getApplicationContext();
    qiitaItemsSubject = app.getQiitaItemsSubject();
    subscriptions = new CompositeSubscription();
}