Home
last modified time | relevance | path

Searched refs:lineStartIndex (Results 1 – 2 of 2) sorted by relevance

/tools/trebuchet/core/common/src/main/kotlin/trebuchet/io/
DStreamingLineReader.kt35 var lineStartIndex = stream.startIndex in <lambda>() variable
37 var index = lineStartIndex in <lambda>()
50 if (lineStartIndex > stream.endIndex) break in <lambda>()
61 if (lineStartIndex >= stream.startIndex && (lineEndIndexInclusive - lineStartIndex) >= 0) { in <lambda>()
62 val window = stream.windowFor(lineStartIndex) in <lambda>()
65 yield(window.slice.slice((lineStartIndex - window.globalStartIndex).toInt(), in <lambda>()
68 val tmpBuffer = ByteArray((lineEndIndexInclusive - lineStartIndex + 1).toInt()) in <lambda>()
69 stream.copyTo(tmpBuffer, lineStartIndex, lineEndIndexInclusive) in <lambda>()
73 lineStartIndex = nextStart in <lambda>()
DStreamingReader.kt103 fun copyTo(tmpBuffer: ByteArray, lineStartIndex: Long, lineEndIndex: Long) { in get()
104 var srcIndex = lineStartIndex in get()