Es RxJava una buena opción para ramificar flujos de trabajo?

Estoy usando RxJava para procesar algunas notificaciones que extraemos de una cola. RxJava parecía funcionar bien con un flujo de trabajo simple, ahora con nuevos requisitos, el flujo está creciendo en complejidad con más ramas (vea la imagen a ...