NewsFragment.kt

newsViewModel!!.newsRepository.getNews(PAGE_KEY, PAGE_SIZE)
                .subscribe(object : Observer<NewsAPIResponse> {
                    override fun onSubscribe(d: Disposable) {
                        Log.d(LOGGER, "onSubscribe of loadInitial")
                    }

                    override fun onNext(newsAPIResponse: NewsAPIResponse) {
                        Log.d(LOGGER, "onNext of loadInitial - " + newsAPIResponse.data?.size)
                        val news = processModelData(newsAPIResponse)
                        
                    }

                    override fun onError(e: Throwable) {
                        Log.d(LOGGER, "onError of loadInitial - " + e.message)
                    }

                    override fun onComplete() {
                        Log.d(LOGGER, "onComplete of loadInitial")
                    }
})