I think of it as retryWhen "starts the flow over" for downstream consumers. Under the covers, the flow subscription(is that the right Kotlin term) was canceled, and a new subscription was started. So make sure the makeQuery func sets up anything it needs(and isn't relying on inbound state somehow)