Rx java repeat

Implementation of repeat. 

There is an issue with toBlockingObservable when using currentThread().