有没有办法在异常抛出akka streams时获得映射的项？

import akka.stream.scaladsl._
import akka.stream._
import akka.NotUsed
import scala.concurrent.Future

case class MyException(message: String) extends Exception(message)

val source: Source[Int, NotUsed] = Source(1 to 10)

val mappedSource: Source[Int, NotUsed] = source
  .map { num =>
    if (num % 2 == 0) {
      throw MyException(s"Even number: $num")
    } else {
      num
    }
  }
  .mapError {
    case ex: MyException => new RuntimeException("Mapped exception: " + ex.getMessage)
    case ex => ex // Pass through other exceptions
  }

val result: Future[Done] = mappedSource.runForeach(println)
result.onComplete {
  case scala.util.Success(_) => println("Stream completed successfully")
  case scala.util.Failure(ex) => println("Stream failed with exception: " + ex.getMessage)
}