BlogPresenter.kt

class BlogPresenter(val blogRepository: BlogRepository, val view : BlogView) {

    fun blogs() {
        val disposable = blogRepository.blogs()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeWith(object : DisposableObserver<List<Blog>>() {
                    override fun onComplete() {
                        
                    }

                    override fun onNext(blogs: List<Blog>) {
                        blogView.setBlogs(blogs)
                    }

                    override fun onError(e: Throwable) {
                        
                    }

                })
           compositeDisposable.add(disposable)
    }

}