java8 stream api でいうところの peek をするには doOnNext を利用すればよい。
http://stackoverflow.com/questions/30760768/rxjava-performing-a-peek-or-void-operation-within-an-observable-chain