Hi guys, I’ve got a question about `Observable.pub...

# rx

[yougin]

Hi guys, I’ve got a question about Observable.publish() like it’s being used here https://github.com/oldergod/android-architecture/blob/fce08933127666abd041f408a5cf3981f023225d/app/src/main/java/com/example/android/architecture/blueprints/todoapp/tasks/TasksActionProcessorHolder.java#L148

var actionProcessor =
      ObservableTransformer<TasksAction, TasksResult> { actions ->
        actions.publish { shared -> // publish({}) is being used
          Observable.merge( // no behavior changes if I only use this part
              shared.ofType(TasksAction.LoadTasksAction::class.java).compose(loadTasksProcessor),
              shared.ofType(TasksAction.ActivateTaskAction::class.java).compose(activateTaskProcessor),
              ...
        }
      }

I don’t quite get why an Observable is being published first to split the upstream one (actions in this case). `