Markus markus2610

Local Inspections

@SuppressWarnings("UndesirableClassUsage")
@SuppressWarnings("FileEqualsUsage")
@SuppressWarnings("GtkPreferredJComboBoxRenderer")
@SuppressWarnings("UnsafeVfsRecursion")
@SuppressWarnings("ConstantConditions")
@SuppressWarnings("UnusedAssignment")
@SuppressWarnings("NumericOverflow")
@SuppressWarnings("RedundantCast")

Writing Resilient Reactive Applications

This guide is a first draft (that will end up in the official docs) on writing resilient code for production with the Couchbase Java SDK. At the end, the reader will be able to write code that withstands bugs, latency issues or anything else that can make their application fail.

Note that lots of concepts can be applied for both synchronous and asynchronous access. When necessary, both patterns are discussed separately. Also, the focus is on database interaction, but if you are using RxJava as part of your stack you can apply most of the principles there as well (and should!).

RxJava 101 Recap: Cold and Hot Observables

When working with Observables, it is important to understand the difference between cold and hot. Cold Observables will start to emit events once a Observer subscribes, and will do it "fresh" for each Observer. Hot Observables instead are starting to emit data as soon as it becomes available, and will return the same (or parts of the same)

This short code will show how to sync database file using Realm, but can be used for any file that you need to send to Wear (using Data API). It just takes any file, change it to Asset object and send it over to Wear device. Also it can be used Mobile->Wear, and Wear->Mobile.

When you need to sync database just call FileSender.syncRealm(context);, that is it!

DISCLAIMER "Proper" way would be to synchronize each transaction to DB, but it in most cases Wear is used very rarely comparing to mobile, so it would most likely cause a battery drain. My idea was to synchronize it only whene it is needed (so for example when app closes). If you want to make sure that you are using latest DB, just send trigger data using MessageAPI from Wear to Phone with ask of syncing over its database, or keep some timestapm of last edit and check it.

	import java.io.IOException;
	import java.lang.reflect.Method;
	import java.util.AbstractCollection;
	import java.util.ArrayList;
	import java.util.EnumSet;
	import java.util.HashMap;
	import java.util.Iterator;
	import java.util.Map;
	import android.media.AudioManager;
	import android.media.MediaPlayer;

	import android.content.Context;
	import android.content.res.TypedArray;
	import android.graphics.Canvas;
	import android.graphics.Rect;
	import android.graphics.drawable.Drawable;
	import android.support.v4.content.ContextCompat;
	import android.support.v7.widget.LinearLayoutManager;
	import android.support.v7.widget.RecyclerView;
	import android.util.AttributeSet;
	import android.view.View;

	Unless specified otherwise, all of the below tinting applies to both Lollipop and pre-Lollipop using AppCompat v21. To use the support version of these attributes, remove the android namespace. For instance, "android:colorControlNormal" becomes "colorControlNormal". These attributes will be propagated to their corresponding attributes within the android namespace for devices running Lollipop. Any exceptions to this will be noted by including the "android:" prefix.

	All Clickable Views:
	-----------
	* ripple effect (Lollipop only) -- "colorControlHighlight"

	Status Bar:
	------------
	* background (Lollipop only) - "colorPrimaryDark"

	import android.graphics.Color;
	import android.support.design.widget.TextInputLayout;
	import android.text.Editable;
	import android.text.Layout;
	import android.text.SpannableStringBuilder;
	import android.text.Spanned;
	import android.text.TextWatcher;
	import android.text.style.AlignmentSpan;
	import android.text.style.ForegroundColorSpan;

	import android.graphics.Color;
	import android.support.design.widget.TextInputLayout;
	import android.text.Editable;
	import android.text.Layout;
	import android.text.SpannableStringBuilder;
	import android.text.Spanned;
	import android.text.TextWatcher;
	import android.text.style.AlignmentSpan;
	import android.text.style.ForegroundColorSpan;

	import android.support.v7.widget.LinearLayoutManager;
	import android.support.v7.widget.RecyclerView;

	public abstract class EndlessRecyclerOnScrollListener extends RecyclerView.OnScrollListener {
	public static String TAG = EndlessRecyclerOnScrollListener.class.getSimpleName();

	private int previousTotal = 0; // The total number of items in the dataset after the last load
	private boolean loading = true; // True if we are still waiting for the last set of data to load.
	private int visibleThreshold = 5; // The minimum amount of items to have below your current scroll position before loading more.
	int firstVisibleItem, visibleItemCount, totalItemCount;

	package com.example.util.shadow;

	import android.graphics.Canvas;
	import android.graphics.Color;
	import android.graphics.Rect;
	import android.graphics.drawable.GradientDrawable;
	import android.view.View;

	import static android.graphics.drawable.GradientDrawable.Orientation.LEFT_RIGHT;
	import static android.graphics.drawable.GradientDrawable.Orientation.TOP_BOTTOM;