RxKotlin Debug extension

gistfile1.txt

import io.reactivex.rxjava3.core.Observable
import timber.log.Timber

fun <T : Any> Observable<T>.debug(customTag: String? = null): Observable<T> {
  val fileTag = Exception().stackTrace[0].fileName
  val tag = if (customTag == null) fileTag else "$fileTag - $customTag"
  val line = Exception().stackTrace[0].lineNumber
  return this
    .doOnNext { item ->
      Timber.tag(tag).d("[LINE $line] Next item: $item")
    }.doOnComplete {
      Timber.tag(tag).d("[LINE $line] Completed")
    }.doOnError { error ->
      Timber.tag(tag).d("[LINE $line] Error: $error")
    }
}