design-patterns - 如何在 Scala 中编写聚合模式？

Question

假设我有 Iterator[A] ( 大小是无限的 )我想得到 Iterator[B]从中聚合了类型 A 的一些后续值。

例子:
我有字符串列表:

Iterator(
    "START",
    "DATA1",
    "DATA2",
    "DATA3",
    "START",
    "DATA1",
    "DATA2",
    //.. 10^10 more records
)

我想将字符串从 START 加入到 NEXT START 除外。 IE。写解析器。

Iterator(
"START DATA1 DATA2 DATA3",
"START DATA1 DATA2",
    //.. 10^10 / 5 more records
)

我知道如何强制执行此操作，但我想使用 Scala 高阶函数来完成它。有任何想法吗？

PS EIP聚合 http://camel.apache.org/aggregator2.html .

Answer 1

如果你想要一个功能性的解决方案，你应该使用流而不是迭代器(流是不可变的)。这是一种可能的方法:

def aggregate(strs: Stream[String] ) = { 
  aggregateRec( strs )
}

def aggregateRec( strs: Stream[String] ): Stream[String] = {
  val tail = strs.drop(1)
  if( tail.nonEmpty ) {
    val (str, rest ) = accumulate( tail )
    Stream.cons( str, aggregateRec( rest ) )
  }
  else Stream.empty
}

def accumulate( strs: Stream[String] ): (String, Stream[String])  = {
  val first = "START " + strs.takeWhile( _ != "START").mkString(" ")
  val rest = strs.dropWhile( _ != "START" )
  ( first, rest )
}

它按预期工作:

val strs = Stream( "START", "1", "2", "3", "START", "A", "B" )
val strs2 = aggregate( strs )
strs2 foreach println