PierceZ

public class MainEmptyActivity extends AppCompatActivity {
    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        Intent activityIntent;

        // go straight to main if a token is stored
        if (Util.getToken() != null) {
            activityIntent = new Intent(this, MainActivity.class);

PierceZ

public final class LiveDataBus {

    private static SparseArray<EventLiveData> sSubjectMap = new SparseArray<>();

    public static final int SUBJECT_DATA_LOADED = 0, SUBJECT_DOWNLOAD_COMPLETE = 1;

    @Retention(SOURCE)
    @IntDef({SUBJECT_DATA_LOADED, SUBJECT_DOWNLOAD_COMPLETE})
    @interface Subject {

PierceZ

Observable.fromCallable(() -> {
    Request request = new Request.Builder()
            .url(url)
            .build();
    try {
        Response response = sHttpClient.newCall(request).execute();
        return response.isSuccessful();
    } catch (IOException e) {
        Log.e("Network request", "Failure", e);
    }

PierceZ

<android.support.constraint.ConstraintLayout
    android:layout_width="match_parent"
    android:layout_height="wrap_content">

    <android.support.constraint.Guideline
        android:id="@+id/guideline1"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:orientation="vertical"
        app:layout_constraintGuide_percent="0.25"/>

PierceZ

public class EventLiveData extends LiveData<Object> {

    private final int mSubject;
    private final LifecycleRegistryOwner mLifecycle;

    public EventLiveData(@LiveDataBus.Subject int subject, @NonNull LifecycleRegistryOwner lifecycle) {
        mSubject = subject;
        mLifecycle = lifecycle;
    }

PierceZ

public class EventLiveData extends LiveData<Object> {

    private final int mSubject;

    public EventLiveData(@LiveDataBus.Subject int subject) {
        mSubject = subject;
    }

    public void update(Object object) {
        postValue(object);

PierceZ

//Example Activity
public class MyActivity extends BaseActivity {
    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.myactivity);
      
        // with lambda
        LiveDataBus.subscribe(LiveDataBus.SUBJECT_DATA_LOADED, this, (data) -> {

PierceZ

public class ZooDAO {

    private static Box<Zoo> getZooBox() {
        BoxStore boxStore = App.getBoxStore();
        return boxStore.boxFor(Zoo.class);
    }

    public static DataSubscription subscribeToZooList(DataObserver<List<Zoo>> observer) {
        return getZooBox().query().build().subscribe().on(AndroidScheduler.mainThread()).observer(observer);
    }

PierceZ

/**
 * Will process the data with the callable by splitting the data into the specified number of threads.
 * <b>T</b> is ths type of data being parsed, and <b>U</b> is the type of data being returned.
 */
public static <T, U> Iterable<U> parseDataInParallel(@NonNull List<T> data, Function<List<T>, ObservableSource<U>> worker) {
    int threadCount = Runtime.getRuntime().availableProcessors();
    ExecutorService threadPoolExecutor = Executors.newFixedThreadPool(threadCount);
    Scheduler scheduler = Schedulers.from(threadPoolExecutor);

    AtomicInteger groupIndex = new AtomicInteger();

PierceZ

/**
 * Used for subscribing to and publishing to subjects. Allowing you to send data between activities, fragments, etc.
 * <p>
 * Created by Pierce Zaifman on 2017-01-02.
 */

public final class RxBus {

    private static SparseArray<PublishSubject<Object>> sSubjectMap = new SparseArray<>();
    private static Map<Object, CompositeDisposable> sSubscriptionsMap = new HashMap<>();