• Шаг 1 ФИО, типа образования, наличия опыта работы,
  
• Шаг 2 место учёбы,
  
• Шаг 3 место работы или эссе о себе,
  
• Шаг 4 причины, почему заинтересовала вакансия.
  

• Как сделать сценарий фичи гибким и иметь возможность легко добавлять и убирать шаги.
  
• Как гарантировать, что при открытии шага нужные данные уже будут заполнены (например, экран Образование на вход ждёт уже известный тип образования, чтобы перестроить состав своих полей).
  
• Как агрегировать данные в общую модель для передачи на сервер после заключительного шага.
  
• Как сохранить заявку в черновик, чтобы пользователь мог прервать заполнение и вернуться к нему позже.
  

Очевидное решение

class Application(    val name: String?,    val surname: String?,    val educationType : EducationType?,    val workingExperience: Boolean?    val education: Education?,    val experience: Experience?,    val motivation: List<Motivation>?)

Как сделать лучше

• Безболезненно менять шаги в сценарии: например, перекрывать дальнейшую работу, если в ходе выполнения выясняется, что пользователю нельзя подавать заявки или добавлять шаги, если информации нужно больше.
  
• Задавать контракты: какие данные обязаны быть на входе и на выходе каждого шага.
  
• Организовать сохранение заявки в черновик, если пользователь не прошёл все экраны.
  

Основные сущности

• Набора моделей для описания шага, входных и выходных данных.
  
• Сценария (Scenario) сущности, описывающей, какие шаги (экраны) нужно пройти пользователю.
  
• Интерактора (ProgressInteractor) класса, отвечающего за хранение информации о текущем активном шаге, агрегирование заполненной информации после завершения каждого шага и выдачу входных данных для старта нового шага.
  
• Черновика (ApplicationDraft) класса, отвечающего за хранение заполненной информации.
  

Описание шагов

//Маркерный интерфейс, чтобы обозначить классы, являющиеся шагами в сценарииinterface Step

/** * Шаги в фиче заполнения заявки */enum class ApplicationSteps : Step {    PERSONAL_INFO,  // персональные данные    EDUCATION,      // образование    EXPERIENCE,     // опыт работы    ABOUT_ME,       // эссе "о себе"    MOTIVATION      // что интересно в данной вакансии}

//Входные данные для шагаinterface StepInData

//Класс, описывающий входные данные для работы шаговsealed class ApplicationStepInData : StepInData//Входные данные для шага об образованииclass EducationStepInData(val educationType: EducationType) : ApplicationStepInData()//Входные данные для шага о причинах выбора этой вакансииclass MotivationStepInData(val values: List<Motivation>) : ApplicationStepInData()

//Маркерный интерфейс, помечающий результат шагаinterface StepOutData//Класс, описывающий результат прохождения шагаsealed class ApplicationStepOutData : StepOutData//Результат прохождения  шага "Персональная информация"class PersonalInfoStepOutData(    val info: PersonalInfo) : ApplicationStepOutData()//Результат прохождения шага "Образование"class EducationStepOutData(    val education: Education) : ApplicationStepOutData()//Результат прохождения  шага "Места работы"class ExperienceStepOutData(    val experience: WorkingExperience) : ApplicationStepOutData()//Результат прохождения шага "Обо мне"class AboutMeStepOutData(    val info: AboutMe) : ApplicationStepOutData()//Результат прохождения шага "Выбор причин"class MotivationStepOutData(    val motivation: List<Motivation>) : ApplicationStepOutData()

/** * Входные данные для шага + данные из черновика, если они есть */interface StepData<I : StepInData, O : StepOutData>sealed class ApplicationStepData : StepData<ApplicationStepInData,  ApplicationStepOutData> {    class PersonalInfoStepData(        val outData: PersonalInfoStepOutData?    ) : ApplicationStepData()    class EducationStepData(        val inData: EducationStepInData,        val outData: EducationStepOutData?    ) : ApplicationStepData()    class ExperienceStepData(        val outData: ExperienceStepOutData?    ) : ApplicationStepData()    class AboutMeStepData(        val outData: AboutMeStepOutData?    ) : ApplicationStepData()    class MotivationStepData(        val inData: MotivationStepInData,        val outData: MotivationStepOutData?    ) : ApplicationStepData()}

Действуем по сценарию

/** * Интерфейс, которому должны удовлетворять все классы, описывающие порядок шагов в фиче */interface Scenario<S : Step, O : StepOutData> {        // список шагов    val steps: List<S>    /**     * Внесение изменений в сценарий      * в зависимости от выходной информации при завершении шага     */    fun reactOnStepCompletion(stepOut: O)}

class ApplicationScenario : Scenario<ApplicationStep, ApplicationStepOutData> {    override val steps: MutableList<ApplicationStep> = mutableListOf(        PERSONAL_INFO,        EDUCATION,        EXPERIENCE,        MOTIVATION    )    override fun reactOnStepCompletion(stepOut: ApplicationStepOutData) {        when (stepOut) {            is PersonalInfoStepOutData -> {                changeScenarioAfterPersonalStep(stepOut.info)            }        }    }    private fun changeScenarioAfterPersonalStep(personalInfo: PersonalInfo) {        applyExperienceToScenario(personalInfo.hasWorkingExperience)        applyEducationToScenario(personalInfo.education)    }    /**     * Если нет образования - шаг с заполнением места учёбы будет исключен     */    private fun applyEducationToScenario(education: EducationType) {...}    /**     * Если у пользователя нет опыта работы,     * шаг заполнения мест работы будет заменён на шаг рассказа о себе     */    private fun applyExperienceToScenario(hasWorkingExperience: Boolean) {...}}

/** * Если у пользователя нет опыта работы, * шаг заполнения мест работы будет заменён на шаг рассказа о себе */private fun applyExperienceToScenario(hasWorkingExperience: Boolean) {    if (hasWorkingExperience) {        steps.replaceWith(            condition = { it == ABOUT_ME },            newElem = EXPERIENCE        )    } else {        steps.replaceWith(            condition = { it == EXPERIENCE },            newElem = ABOUT_ME        )    }}

Как устроен Interactor

/** * Базовый класс для интеракторов пошаговых фич * S - входной шаг * I - входные данные для шагов * O - выходные данные для шагов */abstract class ProgressInteractor<S : Step, I : StepInData, O : StepOutData> 

// сущность, отвечающая за состав и порядок шаговprotected abstract val scenario: Scenario<S, O>

/** * Модель для описания шага и его позиции в сценарии */class StepWithPosition<S : Step>(    val step: S,    val position: Int,    val allStepsCount: Int)

private val stepChangeSubject = BehaviorSubject.create<StepWithPosition<S>>()

val stepChangeObservable: Observable<StepWithPosition<S>> = stepChangeSubject.hide()

// текущий активный шагprivate var currentStepIndex: Int    get() = stepChangeSubject.value?.position ?: 0    set(value) {        stepChangeSubject.onNext(            StepWithPosition(                step = scenario.steps[value],                position = value,                allStepsCount = scenario.steps.count()            )        )    }

/** * Инициализация работы интерактора */@CallSuperopen fun initProgressFeature() {    currentStepIndex = 0}/** * Завершение работы интерактора */@CallSuperopen fun closeProgressFeature() {    currentStepIndex = 0}

• getDataForStep(step: S) предоставлять данные на вход шагу S;
  
• completeStep(stepOut: O) сохранять выходные данные O и переводить сценарий на следующий шаг;
  
• toPreviousStep() - переводить сценарий на предыдущий шаг.
  

/** * Метод получения входной информации для шага */protected abstract fun resolveStepInData(step: S): Single<out StepData<I, O>>

/** * Предоставление входных параметров для шага */fun getDataForStep(step: S): Single<out StepData<I, O>> = resolveStepInData(step)

/** * Метод обработки выходной информации для шага */protected abstract fun saveStepOutData(stepData: O): Completable

/** * Завершение текущего шага и переход к следующему */fun completeStep(stepOut: O): Completable {    return saveStepOutData(stepOut).doOnComplete {        scenario.reactOnStepCompletion(stepOut)        if (currentStepIndex != scenario.steps.lastIndex) {            currentStepIndex += 1        }    }}

/** * Переход на предыдущий шаг */fun toPreviousStep() {    if (currentStepIndex != 0) {        currentStepIndex -= 1    }}

/** * Интерактор фичи подачи заявления */@PerApplicationclass ApplicationProgressInteractor @Inject constructor(    private val dataRepository: ApplicationDataRepository) : ProgressInteractor<ApplicationSteps, ApplicationStepInData, ApplicationStepOutData>() {    // сценарий оформления    override val scenario = ApplicationScenario()    // черновик заявки    private val draft: ApplicationDraft = ApplicationDraft()    // установка черновика    fun applyDraft(draft: ApplicationDraft) {        this.draft.apply {            clear()            outDataMap.putAll(draft.outDataMap)        }    }    ...}

/** * Черновик заявки */class ApplicationDraft(    val outDataMap: MutableMap<ApplicationSteps, ApplicationStepOutData> = mutableMapOf()) : Serializable {    fun getPersonalInfoOutData() = outDataMap[PERSONAL_INFO] as? PersonalInfoStepOutData    fun getEducationStepOutData() = outDataMap[EDUCATION] as? EducationStepOutData    fun getExperienceStepOutData() = outDataMap[EXPERIENCE] as? ExperienceStepOutData    fun getAboutMeStepOutData() = outDataMap[ABOUT_ME] as? AboutMeStepOutData    fun getMotivationStepOutData() = outDataMap[MOTIVATION] as? MotivationStepOutData    fun clear() {        outDataMap.clear()    }}

/** * Сохранение выходных данных шага в черновик */override fun saveStepOutData(stepData: ApplicationStepOutData): Completable {    return Completable.fromAction {        when (stepData) {            is PersonalInfoStepOutData -> {                draft.outDataMap[PERSONAL_INFO] = stepData            }            is EducationStepOutData -> {                draft.outDataMap[EDUCATION] = stepData            }            is ExperienceStepOutData -> {                draft.outDataMap[EXPERIENCE] = stepData            }            is AboutMeStepOutData -> {                draft.outDataMap[ABOUT_ME] = stepData            }            is MotivationStepOutData -> {                draft.outDataMap[MOTIVATION] = stepData            }        }    }}

/** * Получение входной информации для шага */override fun resolveStepInData(step: ApplicationStep): Single<ApplicationStepData> {    return when (step) {        PERSONAL_INFO -> ...        EXPERIENCE -> ...        EDUCATION -> Single.just(            EducationStepData(                inData = EducationStepInData(                    draft.getPersonalInfoOutData()?.info?.educationType                    ?: error("Not enough data for EDUCATION step")                ),                outData = draft.getEducationStepOutData()            )        )        ABOUT_ME -> Single.just(            AboutMeStepData(                outData = draft.getAboutMeStepOutData()            )        )        MOTIVATION -> dataRepository.loadMotivationVariants().map { reasonsList ->            MotivationStepData(                inData = MotivationStepInData(reasonsList),                outData = draft.getMotivationStepOutData()            )        }    }}

• пользователь впервые открывает экран;
  
• пользователь уже заполнял экран, и у нас в черновике есть сохранённые данные.
  

 ABOUT_ME -> Single.just(            AboutMeStepData(                stepOutData = draft.getAboutMeStepOutData()            )        )

EDUCATION -> Single.just(    EducationStepData(        inData = EducationStepInData(            draft.getPersonalInfoOutData()?.info?.educationType            ?: error("Not enough data for EDUCATION step")        ),        outData = draft.getEducationStepOutData()    ))

MOTIVATION -> {    dataRepository.loadMotivationVariants().map { reasonsList ->        MotivationStepData(            inData = MotivationStepInData(reasonsList),            outData = draft.getMotivationStepOutData()        )    }}

/** * Модель заявления */class Application(    val personal: PersonalInfo,    val education: Education?,    val experience: Experience,    val motivation: List<Motivation>) {    class Builder {        private var personal: Optional<PersonalInfo> = Optional.empty()        private var education: Optional<Education?> = Optional.empty()        private var experience: Optional<Experience> = Optional.empty()        private var motivation: Optional<List<Motivation>> = Optional.empty()        fun personalInfo(value: PersonalInfo) = apply { personal = Optional.of(value) }        fun education(value: Education) = apply { education = Optional.of(value) }        fun experience(value: Experience) = apply { experience = Optional.of(value) }        fun motivation(value: List<Motivation>) = apply { motivation = Optional.of(value) }        fun build(): Application {            return try {                Application(                    personal.get(),                    education.getOrNull(),                    experience.get(),                    motivation.get()                )            } catch (e: NoSuchElementException) {                throw ApplicationIsNotFilledException(                    """Some fields aren't filled in application                        personal = {${personal.getOrNull()}}                        experience = {${experience.getOrNull()}}                        motivation = {${motivation.getOrNull()}}                    """.trimMargin()                )            }        }    }}

/** * Отправка заявки */fun sendApplication(): Completable {    val builder = Application.Builder().apply {        draft.outDataMap.values.forEach { data ->            when (data) {                is PersonalInfoStepOutData -> personalInfo(data.info)                is EducationStepOutData -> education(data.education)                is ExperienceStepOutData -> experience(data.experience)                is AboutMeStepOutData -> experience(data.info)                is MotivationStepOutData -> motivation(data.motivation)            }        }    }    return dataRepository.loadApplication(builder.build())}

Как всем этим пользоваться на экранах

progressInteractor.stepChangeObservable.subscribe { stepData ->    if (stepData.position > currentPosition) {        // добавляем шаг в стек через FragmentManager    } else {        // убираем из стека    }    // отображение нужного кол-ва закрашенных шагов в тулбаре}

progressInteractor.getDataForStep(EducationStep)    .filter<ApplicationStepData.EducationStepData>()    .subscribeOn(Schedulers.io())    .subscribe {         val educationType = it.stepInData.educationType // todo: вносим изменения в модель в зависимости от типа образования it.stepOutData?.education?.let {       // todo: применяем к экрану данные из черновика  }    }

progressInteractor.completeStep(EducationStepOutData(education)).subscribe {                   // обработка успешного сохранения данных (если нужно)               }

progressInteractor.sendApplication()            .subscribeOn(Schedulers.io())            .observeOn(AndroidSchedulers.mainThread())            .subscribe(                {                    // реакция на успешную отправку                    activityNavigator.start(ThankYouRoute())                },                {                    // обработка ошибок                }            )

progressInteractor.closeProgressFeature()

Переключение потоков и создание

RxJava

Observable.create<Int> { emitter ->emitter.onNext(1)emitter.onNext(2)emitter.onNext(3)emitter.onComplete()}.observeOn(Schedulers.io()).map {printThread(map1 value = $it)it + it}.doOnNext { printThread(after map1 -> $it) }.observeOn(Schedulers.computation()).map {printThread(map2 value = $it)it * it}.doOnNext { printThread(after map2 -> $it) }.observeOn(Schedulers.single()).subscribe ({printThread(On Next $it)},{printThread(On Error)},{printThread(On Complete)})

Flow

launch {flow {emit(1)emit(2)emit(3)}.map {printThread(map1 value = $it)it + it}.onEach { printThread(after map1 -> $it) }.flowOn(Dispatchers.IO).map {printThread(map2 value = $it)it * it}.onEach { printThread(after map2 -> $it) }.flowOn(Dispatchers.Default).onCompletion { printThread(onCompletion) }.collect { printThread(received value $it) }}

• flowOf(): в примере можно было бы использовать Observable.fromArray(1, 2, 3) и flowOf(1, 2, 3)
• extenstion function asFlow(), который превращает Iterable, Sequence, массивы во flow
• билдер flow { }

Подписка и отписка на источник данных

val job = scope.launch {flow.collect { }}job.cancel() // тут произойдет отписка от flow

Обработка ошибок

RxJava

Observable.fromArray(1, 2, 3).map {val divider = Random.Default.nextInt(0, 1)it / divider}.subscribe({ value ->println(value)},{ e ->println(e)})

Flow

flowOf(1, 2, 3).map {val divider = Random.Default.nextInt(0, 1)it / divider}.catch { e -> println(e) }.collect { println(it) }

Операторы

Backpressure

Hot streams

RxJava Subjects

Заключение

int x = 3func(x) {X + 4}

Архитектура, которая подойдет всем

/** * Метод, который сразу возвращает значение, если оно * доступно, или использует  другой поток исполнения, * чтобы получить значение и передать его через callback `onNext()` */public Observable<T> getProduct(String name) {    if (productInCache(name)) {        // Если данные доступны, возвращаем их сразу        return Observable.create(observer -> {           observer.onNext(getProductFromCache(name));           observer.onComplete();        });    } else {        // Иначе задействуем другой поток исполнения        return Observable.<T>create(observer -> {            try {                // Выполняем работу в отдельном потоке                T product = getProductFromRemoteService(name);                // вовращаем значение                observer.onNext(product);                observer.onComplete();            } catch (Exception e) {                observer.onError(e);            }        })        // Говорим Observable использовать планировщик IO        // для создания/получения данных        .subscribeOn(Schedulers.io());    }}

Опыт применения в Android и VIPER

saveProductInteractor.execute(product, new ObserverEntity<Void>() {    @Override    public void onNext(Void aVoid) {        // Сейчас этот метод нам не нужен,        // но мы обязана его реализовать    }    @Override    public void onError(Throwable throwable) {        // Сейчас этот метод используется        // Какой-то код    }    @Override    public void onComplete() {        // И этот метод тоже используется        // Какой-то код    }});

private void checkProduct(int id, Locale locale) {    getProductByIdInteractor.execute(new TypesUtil.Pair<>(id, locale), new ObserverEntity<Product>() {        @Override        public void onNext(Product product) {            getProductInfo(product);        }        @Override        public void onError(Throwable throwable) {            // Какой-то код        }        @Override        public void onComplete() {        }    });}private void getProductInfo(Product product) {    getReviewsByProductIdInteractor.execute(product.getId(), new ObserverEntity<List<Review>>() {        @Override        public void onNext(List<Review> reviews) {            product.setReviews(reviews);            saveProduct(productInfo);        }        @Override        public void onError(Throwable throwable) {            // Какой-то код        }        @Override        public void onComplete() {            // Какой-то код        }    });    getImageForProductInteractor.execute(product.getId(), new ObserverEntity<Image>() {        @Override        public void onNext(Image image) {            product.setImage(image);            saveProduct(product);        }        @Override        public void onError(Throwable throwable) {            // Какой-то код        }        @Override        public void onComplete() {        }    });}private void saveProduct(Product product) {    saveProductInteractor.execute(product, new ObserverEntity<Void>() {        @Override        public void onNext(Void aVoid) {        }        @Override        public void onError(Throwable throwable) {            // Какой-то код        }        @Override        public void onComplete() {            goToSomeScreen();        }    });}

private Observable<Product> getProductById(int id, Locale locale) {    return getProductByIdInteractor.execute(new TypesUtil.Pair<>(id, locale));}private Observable<Product> getProductInfo(Product product) {    return getReviewsByProductIdInteractor.execute(product.getId())    .map(reviews -> {        product.set(reviews);        return product;    })    .flatMap(product -> {        getImageForProductInteractor.execute(product.getId())        .map(image -> {            product.set(image);            return product;        })    });}private Observable<Product> saveProduct(Product product) {    return saveProductInteractor.execute(product);}private doAll(int id, Locale locale) {    // Берем продукт из хранилища    getProductById (id, locale)    // Добавляем информацию    .flatMap(product -> getProductInfo(product))    // Сохраняем все в другое хранилище    .flatMap(product -> saveProduct(product))    // После сохранения продукты в потоке больше не нужны    .ignoreElements()    // Устанавливаем планировщики    .subscribeOn(Schedulers.io())    .observeOn(AndroidSchedulers.mainThread())    // Переходим на другой экран    .subscribe(() -> goToSomeScreen(), throwable -> handleError());}

Концепции в основе

Три кита RxJava

• Возможность для производителя сигнализировать потребителю о том, что больше нет доступных данных (цикл foreach в Iterable завершается и просто возвращается; Observable в этом случае вызывает метод onCompleate).
• Возможность для производителя сообщать потребителю, что произошла ошибка и Observable больше не может испускать элементы (Iterable бросает исключение, если во время итерации возникает ошибка; Observable вызывает метод onError у своего наблюдателя и завершается).

Заключение

1. Причины, почему Netflix начали использовать ReactiveX
2. Презентация RxJava интернет-сообществу
3. Объяснение архитектуры VIPER и пример применения
4. Объяснение ФРП от его создателя
5. Разница между ФРП и реактивным программированием
6. Рассуждение о ФРП
7. Блог Conal Elliot о ФРП

1. Те, кто не понимают зачем RxRelay используется в их проекте и зачем он нужен, чем отличается от Subject
2. Те, кто думают, что RxRelay проглатывает ошибки или после того как произошла ошибка RxRelay продолжит работать, а Subject нет (та самая магия)
3. Те, кто действительно знает, что такое RxRelay.

class MainActivity : AppCompatActivity() {   private val relay = PublishRelay.create<Int>()   private var isError: Boolean = false   override fun onCreate(savedInstanceState: Bundle?) {       super.onCreate(savedInstanceState)       setContentView(R.layout.activity_main)       val disposable1 = relay           .map {               if (isError) {                   isError = false                   throw Exception()               } else {                   isError = true               }           }.subscribe(               {                   Log.d("test", "Цепочка с ошибкой: onNext")               },               {                   Log.d("test", "Цепочка с ошибкой: onError")               }           )       val disposable2 = relay           .subscribe(               {                   Log.d("test", "Цепочка без ошибки: onNext")               },               {                   Log.d("test", "Цепочка без ошибки: onError")               }           )       btn.setOnClickListener {           relay.accept(1)       }   }}