thomasnield

    import io.reactivex.Observable
    import java.time.LocalTime
    import java.util.concurrent.TimeUnit

    fun main(args: Array<String>) {

        val source = Observable.interval(5, TimeUnit.SECONDS)
                .startWith(0)
                .map {

dlew

public static Action1<Throwable> crashOnError() {
    final Throwable checkpoint = new Throwable();
    return throwable -> {
        StackTraceElement[] stackTrace = checkpoint.getStackTrace();
        StackTraceElement element = stackTrace[1]; // First element after `crashOnError()`
        String msg = String.format("onError() crash from subscribe() in %s.%s(%s:%s)",
            element.getClassName(),
            element.getMethodName(),
            element.getFileName(),
            element.getLineNumber());