yougin
01/20/2019, 3:52 PMval actionProcessor =
ObservableTransformer<TasksAction, TasksResult> { actions ->
Observable.merge(
actions.ofType(TasksAction.LoadTasksAction::class.java).compose(loadTasksProcessor),
actions.ofType(TasksAction.ActivateTaskAction::class.java).compose(activateTaskProcessor)
}