adding the doOnNext breaks the ability to fuse
# rx
j
adding the doOnNext breaks the ability to fuse