我正在尝试Seq[X]
使用相当昂贵的递归算法重构当前生成 a 的组件,以便它生成 a Stream[X]
,因此X
可以按需加载/计算 's ,并且生产者不必事先尝试猜测如何为了满足消费者,它必须做很多挖掘工作。
根据我的阅读,这是“展开”的理想用途,所以这就是我一直试图采取的路线。
这是我的unfold
函数,源自David Pollak 的示例,该函数已经过某位莫里斯先生的审查:
def unfold[T,R](init: T)(f: T => Option[(R,T)]): Stream[R] = f(init) match {
case None => Stream[R]()
case Some((r,v)) => r #:: unfold(v)(f)
}
这里有一棵小树可以试试我们的运气:
case class Node[A](data: A, children: List[Node[A]]) {
override def toString = "Node(" + data + ", children=(" +
children.map(_.data).mkString(",") +
"))"
}
val tree = Node("root", List(
Node("/a", List(
Node("/a/1", Nil),
Node("/a/2", Nil)
)),
Node("/b", List(
Node("/b/1", List(
Node("/b/1/x", Nil),
Node("/b/1/y", Nil)
)),
Node("/b/2", List(
Node("/b/2/x", Nil),
Node("/b/2/y", Nil),
Node("/b/2/z", Nil)
))
))
))
最后,这是我使用展开的广度优先遍历的失败尝试:
val initial = List(tree)
val traversed = ScalaUtils.unfold(initial) {
case node :: Nil =>
Some((node, node.children))
case node :: nodes =>
Some((node, nodes))
case x =>
None
}
assertEquals(12, traversed.size) // Fails, 8 elements found
/*
traversed foreach println =>
Node(root, children=(/a,/b))
Node(/a, children=(/a/1,/a/2))
Node(/b, children=(/b/1,/b/2))
Node(/b/1, children=(/b/1/x,/b/1/y))
Node(/b/2, children=(/b/2/x,/b/2/y,/b/2/z))
Node(/b/2/x, children=())
Node(/b/2/y, children=())
Node(/b/2/z, children=())
*/
谁能给我一些关于如何修复(或重写)我的遍历逻辑以便返回所有节点的提示?谢谢!