在Akka流中，onComplete{}回调不会结束的原因可能是因为流本身没有正常完成或者遇到了异常导致流被中断。为了解决这个问题，可以采取以下几种方法：

1. 使用recoverWithRetries()方法：该方法可以在流遇到异常时自动重试指定次数。可以在recoverWithRetries()方法的回调中处理异常情况，并在重试之后继续流的处理。

source
  .via(flow)
  .recoverWithRetries(3, {
    case _: Exception => Source.empty // 处理异常情况，例如返回一个空的Source来中断流的处理
  })
  .runWith(sink)
  .onComplete {
    case Success(_) => // 成功处理流
    case Failure(ex) => // 处理流失败
  }

2. 使用watchTermination()方法：该方法可以监视流的完成情况，并在流完成后执行一些操作。可以在watchTermination()方法的回调中处理流的完成情况，例如在流未正常完成时强制结束流的处理。

val (completionPromise, completionFuture) = Promise[Done]().watchTermination()(Keep.both)

source
  .via(flow)
  .map { element =>
    // 处理流的元素
  }
  .to(sink)
  .run()
  .onComplete {
    case Success(_) => completionPromise.success(Done) // 成功完成流
    case Failure(ex) => completionPromise.failure(ex) // 处理流失败
  }

completionFuture.onComplete {
  case Success(_) => // 成功处理完成情况
  case Failure(ex) => // 处理完成情况失败
}

通过上述方法，可以有效地处理Akka流中的onComplete{}不会结束的问题，并在流完成或遇到异常时进行相应的处理。