Added toObservableWithReplyLatest implementation and their tests