in cassovary-core/src/main/scala/com/twitter/cassovary/util/io/ListOfEdgesGraphReader.scala [114:125]
def next() = {
val curr = _next.get
val expectedFromId = curr(0)
_next = nodeIds find { case (from, to) =>
val accum = from == expectedFromId
if (accum) curr += to
!accum
} map { case (from, to) =>
startNewBuf(from, to)
}
curr
}