java类android.databinding.ObservableInt的实例源码

public SSLessonsViewModel(Context context, DataListener dataListener, String ssQuarterlyIndex) {
    this.context = context;
    this.dataListener = dataListener;
    this.ssQuarterlyIndex = ssQuarterlyIndex;

    mDatabase = FirebaseDatabase.getInstance().getReference();
    mDatabase.keepSynced(true);

    ssLessonsLoadingVisibility = new ObservableInt(View.INVISIBLE);
    ssLessonsEmptyStateVisibility = new ObservableInt(View.INVISIBLE);
    ssLessonsErrorStateVisibility = new ObservableInt(View.INVISIBLE);
    ssLessonsCoordinatorVisibility = new ObservableInt(View.INVISIBLE);

    shared = PreferenceManager.getDefaultSharedPreferences(context);

    loadQuarterlyInfo();
}

@Test
public void takeTakesCorrectTimes() throws Exception {
    int int1 = 123;
    int int2 = 32;
    ObservableInt observed = new ObservableInt(int1);
    ObservableInt observing = Cinder.computeInt(()->
                    observed.get()
            , observed).take(2).immediate();
    assertTrue(observing.get() == int1);

    observed.set(int2);
    assertTrue(observing.get() == int2);

    observed.set(int1);
    assertTrue(observing.get() == int2);
}

@Test
public void skipSkipsCorrectTimes() throws Exception {
    int int1 = 123;
    int int2 = 32;
    ObservableInt observed = new ObservableInt();
    ObservableInt observing = Cinder.computeInt(()->
                    observed.get()
            , observed).skip(1);

    observed.set(int1);
    assertTrue(observing.get() == 0);

    observed.set(int2);
    assertTrue(observing.get() == int2);

    observed.set(int1);
    assertTrue(observing.get() == int1);
}

public RepositoryViewModel(Context context, final Repository repository) {
    this.repository = repository;
    this.context = context;
    this.ownerName = new ObservableField<>();
    this.ownerEmail = new ObservableField<>();
    this.ownerLocation = new ObservableField<>();
    this.ownerLayoutVisibility = new ObservableInt(View.INVISIBLE);
    this.ownerEmailVisibility = new ObservableInt(View.VISIBLE);
    this.ownerLocationVisibility = new ObservableInt(View.VISIBLE);
    // Trigger loading the rest of the user data as soon as the view model is created.
    // It's odd having to trigger this from here. Cases where accessing to the data model
    // needs to happen because of a change in the Activity/Fragment lifecycle
    // (i.e. an activity created) don't work very well with this MVVM pattern.
    // It also makes this class more difficult to test. Hopefully a better solution will be found
    loadFullUser(repository.owner.url);
}

public BaseLibraryActivityViewModel(Context context, boolean fitSystemWindows) {
    super(context);

    mFitSystemWindows = fitSystemWindows;
    mExpandedHeight = getDimensionPixelSize(R.dimen.miniplayer_height);
    mAnimateSlideInOut = false;

    mMiniplayerHeight = new ObservableInt(0);
    mMiniplayerAlpha = new ObservableFloat(1.0f);
    mNowPlayingToolbarAlpha = new ObservableFloat(0.0f);

    int backgroundColor = getColor(R.color.background);
    mNowPlayingBackground = new ColorDrawable(backgroundColor);

    setPlaybackOngoing(false);
}

@Inject
public SignInViewModel(@SuppressWarnings("UnusedParameters") EventBus eventBus) {
    displayedChild = new ObservableInt(0);
    onNavigationItemSelectedListener = new BottomNavigationView.OnNavigationItemSelectedListener() {
        @Override
        public boolean onNavigationItemSelected(@NonNull MenuItem item) {
            displayedChild.set(item.getItemId() == R.id.tab_signin ? 0 : 1);
            return true;
        }
    };
}

Listener(final ObservableInt observableInt, final Observer<? super Integer> observer) {
  this.observableInt = observableInt;
  this.onPropertyChangedCallback =
      new android.databinding.Observable.OnPropertyChangedCallback() {
        @Override
        public void onPropertyChanged(android.databinding.Observable observable,
            int ignoredPropertyId) {
          if (!isDisposed()) {
            ObservableInt observableInt = (ObservableInt) observable;
            observer.onNext(observableInt.get());
          }
        }
      };
}

@Inject
public SignInViewModel(@SuppressWarnings("UnusedParameters") EventBus eventBus) {
    displayedChild = new ObservableInt(0);
    onNavigationItemSelectedListener = new BottomNavigationView.OnNavigationItemSelectedListener() {
        @Override
        public boolean onNavigationItemSelected(@NonNull MenuItem item) {
            displayedChild.set(item.getItemId() == R.id.tab_signin ? 0 : 1);
            return true;
        }
    };
}

public FollowersInfoViewModel(@NonNull DataListener dataListener, @NonNull Context context,
                              Session session, User user) {
    this.dataListener = dataListener;
    this.context = context;
    this.session = session;
    this.user = user;

    activityFollowersInfoRecyclerView = new ObservableInt(View.GONE);

    initializeViews();
    fetchTweetsList();
}

public FollowersViewModel(@NonNull DataListener dataListener, @NonNull Context context,
                          TwitterSession session, Long userId) {
    this.dataListener = dataListener;
    this.context = context;
    this.session = session;
    this.userId = userId;
    activityFollowerProgressBar = new ObservableInt(View.VISIBLE);
    activityFollowerSwipeRefreshLayout = new ObservableInt(View.GONE);
    activityFollowerRecyclerView = new ObservableInt(View.GONE);
    activityFollowerIsPullToRefresh = new ObservableBoolean(false);
    initializeViews();
    fetchFollowersList(false, false, cursor);
}

public SSLoginViewModel(Context context) {
    this.context = context;
    this.ssLoginLoadingVisibility = new ObservableInt(View.INVISIBLE);
    this.ssLoginControlsVisibility = new ObservableInt(View.VISIBLE);

    this.configureGoogleLogin();
    this.configureFacebookLogin();
    this.configureFirebase();
}

public SSQuarterliesViewModel(Context context, final DataListener dataListener, SsQuarterliesActivityBinding ssQuarterliesActivityBinding) {
    this.context = context;
    this.dataListener = dataListener;
    this.ssQuarterliesActivityBinding = ssQuarterliesActivityBinding;
    ssQuarterliesLoadingVisibility = new ObservableInt(View.INVISIBLE);
    ssQuarterliesListVisibility = new ObservableInt(View.INVISIBLE);
    ssQuarterliesLanguageFilterVisibility = new ObservableInt(View.GONE);
    ssQuarterliesErrorMessageVisibility = new ObservableInt(View.INVISIBLE);
    ssQuarterliesEmptyStateVisibility = new ObservableInt(View.INVISIBLE);
    ssQuarterliesErrorStateVisibility = new ObservableInt(View.INVISIBLE);
    ssQuarterliesListMarginTop = new ObservableFloat(0);
    ssFirebaseDatabase = FirebaseDatabase.getInstance().getReference();
    ssFirebaseDatabase.keepSynced(true);

    this.ssQuarterlyLanguages = new ArrayList<>();
    this.ssQuarterlies = new ArrayList<>();

    SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(context);


    String ssLastLanguageSelected = prefs.getString(SSConstants.SS_LAST_LANGUAGE_INDEX, "");
    ssDefaultLanguage = Locale.getDefault().getLanguage();

    if (!ssLastLanguageSelected.isEmpty()){
        ssDefaultLanguage = ssLastLanguageSelected;
    }

    ssQuarterlyLanguage = new SSQuarterlyLanguage(ssDefaultLanguage, getDisplayLanguageByCode(ssDefaultLanguage), 1);

    loadLanguages();
}

/**
 * Default constructor.
 * @param context The context of the current activity.
 */
public ExplorerViewModel(Context context) {
    this.context = context;
    this.isLoading = new ObservableBoolean(false);
    this.isRefreshing = new ObservableBoolean(false);
    this.files = new ObservableArrayList<FileViewModel>();
    this.isSelectionMode = new ObservableBoolean(false);
    this.numberSelectedItems = new ObservableInt(0);
    this.changeDirectory("/");
}

public BrowseThingViewModel(Context context, LoaderManager loaderManager, DataListener<T> dataListener) {
    this.context = context;
    this.loaderManager = loaderManager;
    this.dataListener = dataListener;
    infoMessageVisibility = new ObservableInt(View.VISIBLE);
    progressVisibility = new ObservableInt(View.INVISIBLE);
    recyclerViewVisibility = new ObservableInt(View.INVISIBLE);
    searchButtonVisibility = new ObservableInt(View.GONE);
    infoMessage = getInfoObservableField(context);
}

@Test
public void computesArrayList() throws Exception {
    final int NUMBER_1 = 23;
    final int NUMBER_2 = 56;
    final ObservableInt number = new ObservableInt(NUMBER_1);
    final ObservableArrayList<Integer> ints =
            Cinder.<Integer>computeArrayList((list)->list.add(number.get()), number).immediate();
    assertEquals(ints.get(0).longValue(), NUMBER_1);

    number.set(NUMBER_2);
    assertEquals(ints.get(1).longValue(), NUMBER_2);
}

@Test
public void computesInt() throws Exception {
    int int1 = 4321;
    int int2 = 23;
    ObservableInt obsInt = new ObservableInt(int1);
    ObservableInt computedInt = Cinder.computeInt(()->obsInt.get(), obsInt).immediate();
    assertEquals(computedInt.get(), int1);

    obsInt.set(int2);
    assertEquals(computedInt.get(), int2);
}

@Test
public void computableMapsAreComputable() throws Exception {
    String key1 = "KEY 1";
    String key2 = "KEY 2";
    String value1 = "VALUE 1";
    String value2 = "VALUE 2";
    ObservableArrayMap<String, String> strings = new ObservableArrayMap<>();
    strings.put(key1, value1);
    ObservableInt computedCount = Cinder.computeInt(()->strings.size(),
            Cinder.observable(strings)).immediate();
    assertEquals(computedCount.get(), 1);

    strings.put(key2, value2);
    assertEquals(computedCount.get(), 2);
}

@Test
public void observesObservables() throws Exception {
    int int1 = 4321;
    int int2 = 23;
    ObservableInt observedInt = new ObservableInt();
    ObservableInt observingInt = new ObservableInt();

    Cinder.observe(()->observingInt.set(observedInt.get()), observedInt);
    observedInt.set(int1);
    assertEquals(observingInt.get(), int1);

    observedInt.set(int2);
    assertEquals(observingInt.get(), int2);
}

@Test
public void onceTakesOnce() throws Exception {
    int int1 = 123;
    int int2 = 43;
    ObservableInt observed = new ObservableInt(int1);
    ObservableInt observing = Cinder.computeInt(()->
            observed.get(), observed).once().immediate();
    assertTrue(observing.get() == int1);

    observed.set(int2);
    assertTrue(observing.get() == int1);
}

@Test
public void filterFilters() throws Exception {
    int int1 = 123;
    int int2 = 32;
    ObservableInt observed = new ObservableInt();
    ObservableInt observing = Cinder.computeInt(()->
                    observed.get()
            , observed).filter(()->observed.get() == int1);

    observed.set(int2);
    assertTrue(observing.get() == 0);

    observed.set(int1);
    assertTrue(observing.get() == int1);
}

@Test
public void takeWhileTakesWhileTrue() throws Exception {
    int int1 = 123;
    int int2 = 32;
    ObservableInt observed = new ObservableInt();
    ObservableInt observing = Cinder.computeInt(()->
                    observed.get()
            , observed).takeWhile(()->observed.get() == int1);

    observed.set(int1);
    assertTrue(observing.get() == int1);

    observed.set(int2);
    assertTrue(observing.get() == int1);
}

@Test
public void skipWhileSkipsWhileTrue() throws Exception {
    int int1 = 123;
    int int2 = 32;
    ObservableInt observed = new ObservableInt();
    ObservableInt observing = Cinder.computeInt(()->
                    observed.get()
            , observed).skipWhile(()->observed.get() == int1);

    observed.set(int1);
    assertTrue(observing.get() == 0);

    observed.set(int2);
    assertTrue(observing.get() == int2);
}

@Test
public void withDefaultAssignsDefault() throws Exception {
    int int1 = 12;
    ObservableInt observing = Cinder.computeInt(()->0
    ).withDefault(int1);

    assertTrue(observing.get() == int1);
}

@Test
public void stopStops() throws Exception {
    int int1 = 123;
    int int2 = 43;
    ObservableInt observed = new ObservableInt(int1);
    CinderInt observing = Cinder.computeInt(()->
            observed.get(), observed).immediate();
    assertTrue(observing.get() == int1);

    observing.stop();

    observed.set(int2);
    assertTrue(observing.get() == int1);
}

@Test
public void convertsObservableIntToRx() throws Exception {
    ObservableInt observableInt = new ObservableInt();
    Observable<Integer> rxInt = RxCinder.convert(observableInt);

    final String TEST_KEY = "TEST_KEY";
    final ArrayMap<String, Integer> testMap = new ArrayMap<>();
    rxInt.subscribe((c)->{
        testMap.put(TEST_KEY, c);});

    final int TEST_INT = 23;
    observableInt.set(TEST_INT);
    assertTrue(testMap.get(TEST_KEY).equals(TEST_INT));
}

@Test
public void convertsRxIntToObservable() throws Exception {
    int TEST_INT = 234;
    Observable<Integer> rxInt = Observable.just(TEST_INT);
    ObservableInt observableInt = RxCinder.convertInt(rxInt);
    assertTrue(observableInt.get() == TEST_INT);
}

PasswordItemViewModel(Navigator navigator, int id, String icon, String name, String username) {
  this.navigator = navigator;
  this.id = new ObservableInt(id);
  this.icon = new ObservableField<>(icon);
  this.name = new ObservableField<>(name);
  this.userName = new ObservableField<>(username);
}

public MainViewModel(){
    getRepos();
    loading = new ObservableInt(View.VISIBLE);
    progressBarVisible = new ObservableInt(View.VISIBLE);
    retryBtnVisible = new ObservableInt(View.INVISIBLE);
    message = new ObservableField<>("loading...");
}

public MainViewModel(@NonNull DataListener dataListener,  @NonNull List<String> keyStore
        , @NonNull DeleteFeedUseCaseFactory deleteFeedUseCaseFactory
        , @NonNull FeedChangedUseCase feedChangedUseCase
        , @NonNull FeedModelMapper mapper, List<FeedModel> model) {

    this.mDataListener = dataListener;
    this.mKeyStore = keyStore;
    this.mDeleteFeedUseCaseFactory = deleteFeedUseCaseFactory;
    this.mMapper = mapper;
    this.mFeedChangedUseCase = feedChangedUseCase;
    mRecyclerViewVisibility = new ObservableInt(View.INVISIBLE);
    this.mFeeds = model;
}

public MainViewModel(Context context, DataListener dataListener) {
    this.context = context;
    this.dataListener = dataListener;
    infoMessageVisibility = new ObservableInt(View.VISIBLE);
    progressVisibility = new ObservableInt(View.INVISIBLE);
    recyclerViewVisibility = new ObservableInt(View.INVISIBLE);
    searchButtonVisibility = new ObservableInt(View.GONE);
    infoMessage = new ObservableField<>(context.getString(R.string.default_info_message));
}