Una buena forma de entender Rxjs es implementado algo similar y mas simple desde 0. Voy a mostrar como componer funciones al estilo como lo hace la librería Rxjs.