在Akka流中返回Future消息的函数可以使用mapAsync操作符来实现。mapAsync操作符可以将流中的每个元素映射为一个Future，并且将这些Future组合成一个新的流。

下面是一个示例代码：

import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._

import scala.concurrent.{ExecutionContext, Future}

object AkkaStreamWithFutureExample extends App {
  // 创建一个隐式的ActorSystem和ActorMaterializer
  implicit val system = ActorSystem("akka-stream-future-example")
  implicit val materializer = ActorMaterializer()
  implicit val executionContext: ExecutionContext = system.dispatcher

  // 定义一个返回Future的函数
  def processElement(element: Int): Future[String] = {
    Future.successful(s"Processed element: $element")
  }

  // 创建一个Source
  val source = Source(1 to 10)

  // 使用mapAsync操作符处理每个元素，并将结果转换为Source
  val processedSource = source.mapAsync(parallelism = 4)(processElement)

  // 创建一个Sink来打印结果
  val sink = Sink.foreach[String](println)

  // 将Source和Sink连接起来，并运行流
  processedSource.runWith(sink).onComplete(_ => system.terminate())
}

在上面的示例中，我们定义了一个名为processElement的函数，它接收一个整数参数并返回一个Future。然后，我们创建了一个Source，其中包含了整数1到10。接下来，我们使用mapAsync操作符将每个元素映射为一个Future，使用parallelism参数指定了并行度。最后，我们创建了一个Sink来打印结果，并将Source和Sink连接起来运行流。

注意，在上述示例中，我们使用了隐式的ActorSystem和ActorMaterializer，并且使用system.dispatcher作为ExecutionContext。这些是必需的，以便正确地执行异步操作和进行线程调度。

希望以上示例代码能够帮助您理解如何在Akka流中返回Future消息的函数。