package app.rehder.domain.movies.interactor

import app.rehder.domain.SingleUseCase
import app.rehder.domain.movies.model.MovieEntity
import app.rehder.domain.movies.repository.MovieRepository
import io.reactivex.Scheduler
import io.reactivex.Single
import io.reactivex.disposables.CompositeDisposable
import javax.inject.Inject
import javax.inject.Named

class GetMovies @Inject constructor(
    private val moviesRepository: MovieRepository,
    @Named("SchedulerIO") executorThread: Scheduler,
    @Named("AndroidScheduler") uiThread: Scheduler,
    @Named("CompositeDisposable") disposable: CompositeDisposable
) : SingleUseCase<List<MovieEntity>, Void?>(executorThread, uiThread, disposable) {

    override fun buildUseCaseObservable(params: Void?): Single<List<MovieEntity>> {
        return moviesRepository.getMovies()
    }
}