=str #16041 Move PersistentSource to the latest Stream DSL

* implemented as an extension of KeyedActorFlowSource