ursus
05/31/2019, 4:40 PMDownloadManager {
val eventsRelay = BehaviourRelay.create<Event>()
val eventsObservable : Observable<Event>
get() = eventsRelay
fun downloadSomething(params) {
apiActuallyDownloadAndWriteObservable(params)
.doOnNext(eventsRelay)
.subscribe {}
}
}