RxJava2: Repeat conditonally / don't repeat in `repeatWhen`

You have to react to the completion indicator by something that signals completion in response to an item, for example:

completed.takeWhile(v -> false);

Unfortunately, empty() doesn't work there because it immediately completes the sequence before the source could even run.