shut down the actor system with OnCompletionSink, so implementation is not leaking out that we are using akka streams in retrieve all