MaybeUseCase.kt

abstract class MaybeUseCase<T>(
    private val schedulersFactory: SchedulersFactory
) {

    abstract fun sourceImpl(params: Params = Params.EMPTY): Maybe<T>

    fun source(params: Params = Params.EMPTY): Maybe<T> =
        sourceImpl(params)
            .subscribeOn(schedulersFactory.useCase())
            .observeOn(schedulersFactory.main())
}