MoviePresenter.kt

@MovieActivityScope
class MoviePresenter @Inject constructor(
    private val movieView: MovieContract.MovieView,
    private val scope: CoroutineScope,
    private val movieModel: MovieModel
) {
    fun onAttach() {
        callMoviesApi()
        observeOnClickStateFlow()
    }

    internal fun callMoviesApi() {
        movieModel.callMoviesApi()
            .onStart {
                movieView.showLoadingView()
            }
            .catch {
                movieView.showErrorView()
            }
            .onEach {
                movieView.showMoviesList(it)
            }
            .onCompletion {
                movieView.hideLoadingView()
            }
            .launchIn(scope)
    }

    internal fun observeOnClickStateFlow() {
        MovieStateFlow.onClickStateFlow.asStateFlow()
            .onEach {
                it?.let {
                    movieView.openSingleItemView(it)
                }
            }
            .catch {
                Log.e("MovieActivity", "Error while observing stateflow$it")
            }.launchIn(scope)
    }
}