aballano

#!/usr/bin/env python

import subprocess
import sys


def run_command(command):
    return subprocess.check_output(command, shell=True, stderr=subprocess.STDOUT).strip()

aballano

sealed class Option<out A> {
    object None : Option<Nothing>()
    data class Some<out A>(val value: A) : Option<A>()

    inline fun <B> map(f: (A) -> B): Option<B> = when (this) {
        is None -> this
        is Some -> Some(f(value))
    }
}

aballano

// Considerably inefficient implementation for test purposes
fun fib(k: Int): Long = when (k) {
    0 -> 1
    1 -> 1
    else -> fib(k - 1) + fib(k - 2)
}

aballano

// Source: http://stackoverflow.com/a/39687177/616119
infix fun <T> Boolean.then(param: T): T? = if (this) param else null

// Usage:

println(condition then "true" ?: "false")

aballano

@Override public Observable showDeleteFailedWithRetry() {
    Snackbar snackbar = Snackbar.make(rootView, "Can't delete chat", Snackbar.LENGTH_LONG);
    Observable<Integer> observable = RxSnackbar.actionClicked(snackbar, "Retry"));
    Observable<Integer> dismissObservable = RxSnackbar.dismisses(snackbar)
              .filter(event -> event != Snackbar.Callback.DISMISS_EVENT_ACTION)
              .flatMap(ignored -> Observable.error(new Throwable()));
    snackbar.show();
    return observable.mergeWith(dismissObservable);
}

aballano

cd ~/.gradle/wrapper/dists/
find . ! -name 'gradle-2.14.1-all' -type d -depth 1 -exec rm -f -r {} +

aballano

public void onDeleteChatAt(int id) {
  interactor.deleteChat(id)
      .retryWhen(errors -> errors.flatMap(error -> view.showDeleteFailedWithRetry()))
      .subscribe(() -> view.removeChat(id), logError())
}

aballano

public void onDeleteChatAt(int id) {
  interactor.deleteChat(id)
      .retryWhen(errors -> view.showDeleteFailedWithRetry())
      .subscribe(() -> view.removeChat(id), logError())
}

aballano

@Override public Observable showDeleteFailedWithRetry() {
    Snackbar snackbar = Snackbar.make(rootView, "Can't delete chat", Snackbar.LENGTH_LONG);
    Observable<Integer> observable = RxSnackbar.actionClicked(snackbar, "Retry"));
    snackbar.show();
    return observable;
}

aballano

public void onDeleteChatAt(int id) {
  interactor.deleteChat(id)
        .subscribe(() -> view.removeChat(id), logError())
}