sebastienrouif

    fun main() {
        var counter = 0
        var emitter: ObservableEmitter<Int>? = null
        val subject = Observable.create<Int> {
            println("emitter creation")
            emitter = it
            it.setCancellable {
                counter = 0
                println("cancelling emitter $it")
            }

sebastienrouif

private SyncStatusObserver mSyncStatusObserver = new SyncStatusObserver() {
        @Override
        public void onStatusChanged(int which) {
            runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    String accountName = AccountUtils.getActiveAccountName(BaseActivity.this);
                    if (TextUtils.isEmpty(accountName)) {
                        onRefreshingStateChanged(false);
                        mManualSyncRequest = false;

sebastienrouif

public class LogUtils {
    private static final String LOG_PREFIX = "myapp_";
    private static final int LOG_PREFIX_LENGTH = LOG_PREFIX.length();
    private static final int MAX_LOG_TAG_LENGTH = 23;

    private LogUtils() {
    }

    public static String makeLogTag(String str) {
        if (str.length() > MAX_LOG_TAG_LENGTH - LOG_PREFIX_LENGTH) {