AlbumsViewModel.kt

class AlbumsViewModel : BaseViewModel {

    private val networkErrorLiveData = BehaviorProcessor.create<Throwable>()
    private val openAlbumDetailsLiveEvent = PublishProcessor.create<Album>()

    fun albumsLiveData(): Flowable<List<Album>> = albumsLiveData.hide().observeOn(AndroidSchedulers.mainThread())
    fun networkErrorLiveData(): Flowable<Throwable> =
        networkErrorLiveData.hide().observeOn(AndroidSchedulers.mainThread())

     fun postAlbums(albums: List<Album>) {
        albumsLiveData.offer(albums)
    }
}