RxJs provides a retry() operator that would automatically resubscribe on error. Problem solved! You can even provide a delay before retrying and decide how many times to retry.