Source.Queue. At some point I know that I've enqueued all messages into it and I need to wait until all of them reached the sink (Sink.Ignore). If I just wait the
ViaMaterialized(Sink.Ignore)returns, I wait forever because the stream is not terminated. Any ideas how to do this?
KillYourself) and raise exception in a
Via(x => ...)added at the end of the stream, but it does not feel right.
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.