Http() .newServerAt("0.0.0.0", port = port) .bindSync(handler(registry)) terminate на таком

Question

Http() .newServerAt("0.0.0.0", port = port) .bindSync(handler(registry)) terminate на таком

работает правильно и сервак выключен когда футурка комплитится
а если делать через стрим то не футурка комплит а сервак работает,
кто-то знает почему?

вот если так стартануть сервак то терминейт футурка комплится до выключения сервака и он успевает обработать еще запрос после комплита футурки

implicit val materializer = SystemMaterializer(system).materializer
Http()
.newServerAt("0.0.0.0", port = port)
.connectionSource()
.to(Sink.foreach(_ handleWithSyncHandler handler(registry)))
.addAttributes(ActorAttributes.dispatcher("metrics-exporter-dispatcher"))
.run()