RxLogObserver

LogObserver.java

public class LogObserver<T> implements Observer<T> {

   private final String tag;

   public LogObserver(String tag) {
       this.tag = tag;
   }

   @Override public void onCompleted() {
       System.out.println(tag + " onCompleted");
   }

   @Override public void onError(Throwable e) {
       System.out.println(tag + " onError: " + e.getMessage());
       e.printStackTrace();
   }

   @Override public void onNext(T s) {
       System.out.println(tag + s);
   }
}

Usage.java

return searchQuery.asObservable()
                  .doOnEach(new LogObserver<String>("search"))
                  .debounce(500, TimeUnit.MILLISECONDS)
                  .doOnEach(new LogObserver<String>("debounce"))
                  .switchMap(...)
                  .doOnEach(new LogObserver<List<Address>>("switchMap"));