如何将Java Stream转为Scala Stream？并用Scala实现指定Java代码逻辑

• 针对Scala 2.13及以上版本，推荐使用scala.jdk.javaapi.StreamConverters工具类完成转换，示例代码：

import scala.jdk.javaapi.StreamConverters
import java.util.stream.Stream

// 初始化Java Stream
val javaStream: Stream[String] = Stream.of("item1", "item2", "item3")
// 转换为Scala Stream
val scalaStream: scala.collection.immutable.Stream[String] = StreamConverters.asScalaStream(javaStream)

• 若使用Scala 2.12及更早版本，可借助scala.collection.JavaConverters的隐式转换：

import scala.collection.JavaConverters._
import java.util.stream.Stream

val javaStream: Stream[String] = Stream.of("item1", "item2", "item3")
val scalaStream: scala.collection.immutable.Stream[String] = javaStream.asScala.toStream

原Java代码的核心逻辑是：生成ISO格式的当前时间，将bidChoices中每个元素格式化生成URI字符串，用逗号拼接后填入模板，最后移除所有换行符。对应的Scala实现如下：

import java.time.OffsetDateTime
import java.time.format.DateTimeFormatter

// 假设以下常量已提前定义：BODY_TEMPLATE、SELECTION_URI_TEMPLATE
private def generateRestBody(baseUrl: String, auctionId: String, baseAuctionId: String, bidChoices: List[String]): String = {
  // 获取ISO偏移格式的当前时间字符串
  val currentTime = DateTimeFormatter.ISO_OFFSET_DATE_TIME.format(OffsetDateTime.now())
  // 映射并拼接URI字符串
  val selectionUris = bidChoices
    .map(slotNo => SELECTION_URI_TEMPLATE.format(baseUrl, auctionId, baseAuctionId, slotNo))
    .mkString(",")
  // 填充模板并移除换行符
  BODY_TEMPLATE.format(currentTime, selectionUris).replaceAll("\n", "")
}

说明：

• Scala列表原生支持map方法，无需手动创建Stream，写法更简洁
• mkString(",")是Scala中拼接集合元素的惯用方式，等价于Java的Collectors.joining(",")
• 直接复用Java的日期API，Scala与Java标准库兼容良好

内容的提问来源于stack exchange，提问作者Banu