This chapter will be using ch07 again to implement services that use ConnectableFlux<T> and Processor<T>.