I did find this post that is similar: Akka source restart with previous state as parameter
I feel like the proposed response in that post may not work well in my use case due to needing this logic to live inside of a larger Flow that processes the data on the fly.