Use unsafeSubscribe() instead of subscribe() for doing recursive subscription in an Rx Operator.