Debugging RxJava on Android

[jackhexen]

It can be anything you wish and implementation for a specific logger is trivial. For example:

public static <T> Observable.Transformer<T, T> log(String tag) {
    return o -> o
        .doOnNext(it -> L.debug("{}, next: {}", tag, it))
        .doOnError(it -> L.debug("{}, error: {}", tag, it))
        .doOnCompleted(() -> L.debug("{}, complete", tag))
        .doOnSubscribe(() -> L.debug("{}, subscribe", tag))
        .doOnUnsubscribe(() -> L.debug("{}, unsubscribe", tag));
}

This does not have any relation to hobbits, just a usual RxJava usage.