def next()

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
        }