Создает ли groupBy в потоке Akka параллельные подпотоки?

Я создал этот пример groupBy -> map -> mergeSubstreamsWithParallelism, используя потоки Akka. В курсе, который я делаю, говорится, что groupBy создаст X подпотоков относительно параметра, который я ему передаю, а затем я должен объединить подпотоки в один поток. Итак, я понимаю, что оператор map работает параллельно. Это правильно?

Если да, то почему я вижу тот же поток, выполняющий оператор map в этом коде:

val textSource = Source(List(
  "I love Akka streams", // odd
  "this has even characters", // even
  "this is amazing", // odd
  "learning Akka at the Rock the JVM", // odd
  "Let's rock the JVM", // even
  "123", // odd
  "1234" // even
))
val totalCharCountFuture = textSource
  .groupBy(2, string => string.length % 2)
  .map { c =>
    println(s"I am running on thread [${Thread.currentThread().getId}]")
    c.length
  }// .async // this operator runs in parallel
  .mergeSubstreamsWithParallelism(2)
  .toMat(Sink.reduce[Int](_ + _))(Keep.right)
  .run()
totalCharCountFuture.onComplete {
  case Success(value) => println(s"total char count: $value")
  case Failure(exception) => println(s"failed computation: $exception")
}

выход:

I am running on thread [16]
I am running on thread [16]
I am running on thread [16]
I am running on thread [16]
I am running on thread [16]
I am running on thread [16]
I am running on thread [16]
total char count: 116

затем я добавил .async, чтобы оператор работал асинхронно. Затем мой вывод показывает разные потоки, выполняющие оператор map:

I am running on thread [21]
I am running on thread [21]
I am running on thread [21]
I am running on thread [20]
I am running on thread [20]
I am running on thread [20]
I am running on thread [20]

Я прочитал документацию в документах Akka об асинхронной границе:

Поместите асинхронную границу вокруг этого потока. Если это подпоток (создается, например, groupBy), это создает асинхронную границу вокруг каждого материализованного подпотока, а не сверхпотока. Таким образом, суперпоток будет взаимодействовать с подпотоками асинхронно.

Итак, мне нужен .async после groupBy, чтобы убедиться, что все подпотоки выполняются параллельно или нет? Является ли этот тест, который я выполняю, подтверждением параллелизма оператора в потоке Akka?

Спасибо