NewsActor

NewsActor.kt

class NewsActors(val apiService: ApiService, val uiService: NewsUiService) {

    val mainActor = actor<Commands> {
        var newsState: States.NewsState = States.NewsState(ListKW.empty())

        for (msg in channel) {
            when (msg) {
                is Commands.NewsGetItemsCommand ->
                    ServiceMonad().binding {
                        uiService.showLoading()
                        val news = apiService.getNews().bind()
                        newsState = newsState.copy(items = news.combineK(newsState.items))
                        uiService.showNews(news).bind()
                        yields(Unit)
                    }.ev().fold({ ex ->
                        when(ex) {
                            is AkmeException.ApiException ->
                                notificationActor.sendBlocking(Notifications.NewsNotLoadedNotification)
                            is AkmeException.UiException ->
                                notificationActor.sendBlocking(Notifications.NewsUiErrorNotification)
                        }
                    }, {})
                is Commands.NewsShowMessageCommand ->
                    uiService.showMessage(msg.item)
            }
        }
    }
 }