update to rxjava 2

[dtingz]

hi
can you please update the example to rxjava 2?

rxjava 2 not supporting null so the logic is diffrent
also please consider what happeing when there is error with network source. it stop the concat flow so please consider it too