RxUtils

Jump to bottom

Jacob Rein edited this page May 5, 2020 · 2 revisions

implementation 'com.github.jakepurple13.HelpfulTools:rxutils:{version}'

RxUtils

To use:

val publish = PublishSubject.create<String>()
publish
    .ioMain()
    .doOnError { println(it) }
    .doOnComplete { println("Done") }
    .subscribe { println(it) }
publish("Hello")
publish.onNext("World")
publish()
publish(Throwable("Error!"))