Scala：用for推导式批量发送列表并返回剩余不足批次的列表

我明白你要做的是：把分组后长度为10的列表传给futureSend异步发送，同时返回所有长度不足10的分组（没有的话返回空列表）。原代码的问题在于for推导式最后yield的是空值，没法收集到剩余分组，而且迭代器的特性也容易踩坑，下面给你两种靠谱的实现方式：

方式一：拆分逻辑，先处理再收集 #

这种方式最直观，先把分组转成List（避免迭代器只能用一次的坑），然后分别处理和收集：

// 先把分组转成List，因为grouped返回的Iterator只能遍历一次
val groupedLists = list.grouped(10).toList

// 第一步：处理所有满10条的分组，调用futureSend
groupedLists.filter(_.size == 10).foreach { batch =>
  futureSend(batch).map(_ => println("sent"))
}

// 第二步：收集长度不足10的分组，这就是要返回的结果
val remainingBatches = groupedLists.filter(_.size != 10)

方式二：用partition一次性拆分（更优雅） #

Scala的partition方法可以直接把列表分成符合条件和不符合条件的两组，逻辑更紧凑：

val groupedLists = list.grouped(10).toList
// 把分组拆成"满10条的"和"不满10条的"两组
val (fullBatches, remainingBatches) = groupedLists.partition(_.size == 10)

// 处理满额的分组
fullBatches.foreach { batch =>
  futureSend(batch).map(_ => println("sent"))
}

// remainingBatches就是需求里要返回的结果，为空则说明所有分组都是满的

几个关键细节要注意： #

• 为什么要转成List？
  grouped(10)返回的是Iterator，迭代器是一次性的——遍历一次后就空了。如果不转成List，你处理完满额分组后，再想收集剩余的就拿不到数据了，这是很容易踩的坑。
• 关于Future的额外提示
  如果需要等待所有异步发送完成，可以用Future.sequence(fullBatches.map(futureSend))把多个Future合并成一个，然后监听完成事件：

  import scala.concurrent.ExecutionContext.Implicits.global
  Future.sequence(fullBatches.map(futureSend)).onComplete { _ =>
    println("所有满额批次都发送完成了")
  }
  

• 原代码的问题
  你原来的for推导式最后yield {}，返回的是一堆Unit值，完全没法收集到剩余分组，这是核心问题所在——我们需要调整逻辑，要么在推导式里筛选并返回剩余分组，要么拆分处理和收集的步骤。

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