在使用Akka Streams时，有时候可能会遇到上下文没有被正确丢弃的问题。这通常发生在将流处理组合在一起时，比如使用flatMapConcat或者flatMapMerge等操作符。这些操作符会创建新的流处理上下文（Stream Processing Context），但是当它们处理完毕后，这些上下文有可能不会被正确地丢弃。

为了避免这个问题，我们可以使用“完成的阶段”（Completion Stage）。这是一个在Java 8 CompletableFuture上构建的新特性，用于在异步执行流处理时正确地管理上下文。在完成的阶段之前，我们需要将流处理操作放入一个单独的函数中，并且该函数的返回值应该是一个CompletionStage，以确保在异步执行时能够正确地管理上下文。下面是一个示例代码：

Source source = Source.single("Hello");
CompletionStage done = source
  .flatMapConcat(str -> {
    // Perform stream processing inside a CompletableFuture
    return CompletableFuture.supplyAsync(() -> {
      System.out.println(str);
      return Done.getInstance();
    });
  }, 1)
  .runWith(Sink.ignore(), materializer);

在上面的示例中，我们将流处理操作放入了一个CompletableFuture中，并在flatMapConcat操作中调用它。我们可以在supplyAsync方法中进行更多的异步操作，并且可以放心地使用它们，因为它们都会在正确的上下文中执行。最后，我们将流处理操作的结果作为CompletionStage返回，并在runWith方法中提供一个Sink以消耗它。

使用完成的阶段能够确保正确地管理上下文，并避免发生上下文泄漏的问题。