How should I handle side-effects in RxJava?

You should consider using the do operators - in this case, doOnNext().

doOn[Next/Error/Completed] are like little side effecting subscriptions that you can put in the sequence. It's not part of the transformation (since they can't transform the data).