getLastSeenThread

TestSubscriber

getOnErrorEvents

TestSubscriber

getOnNextEvents

TestSubscriber

groupBy

Observable

groupJoin

Observable