dependabot-preview[bot] on nuget
Bump Google.Protobuf from 3.12.… (compare)
ISourceQueueWithComplete.WatchCompletionAsync().Wait()is the same as adding
TakeWhile(x => x.IsOk)at the end of stream, it's safe to WatchCompletionAsync.
Does it look too complicated or just not a right job for Persistence (I've never used it before)? One downside of this that I can see is versioning.