Searched refs:StreamingReader (Results 1 – 13 of 13) sorted by relevance
24 import trebuchet.io.StreamingReader35 val reader = StreamingReader(openSample()) in testFactorySuccess()42 val reader = StreamingReader(openSample("sample.ftrace")) in testFactoryNotDeflated()49 val reader = StreamingReader(openSample("caltrace1.html")) in testFactoryNoHeader()58 extractor.extract(StreamingReader(openSample())) { in testExtractInitial()
23 import trebuchet.io.StreamingReader in <lambda>()88 fun makeStream(list: Iterator<String>): StreamingReader { in <lambda>()89 return StreamingReader(object : BufferProducer { in <lambda>()
21 import trebuchet.io.StreamingReader24 fun String.makeReader(): StreamingReader { in makeReader()26 return StreamingReader(object : BufferProducer { in makeReader()
19 import trebuchet.io.StreamingReader30 fun import(stream: StreamingReader): ModelFragment?
23 import trebuchet.io.StreamingReader40 val reader = StreamingReader(stream) in extractOrImport()55 private fun addImporterSource(reader: StreamingReader) { in addImporterSource()
20 import trebuchet.io.StreamingReader34 fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit)
28 override fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit) { in <lambda>()63 private fun processWindow(window: StreamingReader.Window, pipe: Pipe<DataSlice>) { in <lambda>()
42 private class DeflateProducer(stream: StreamingReader, val feedback: ImportFeedback)89 override fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit) { in extract()
22 import trebuchet.io.StreamingReader in <lambda>()41 traceFound: (StreamingReader) -> Unit) { in findTraces()44 val reader = StreamingReader(stream) in findTraces()68 fun copy(reader: StreamingReader, output: OutputStream) { in copy()
26 import trebuchet.io.StreamingReader in <lambda>()36 override fun import(stream: StreamingReader): ModelFragment? { in <lambda>()
21 private fun findNewlineInWindow(window: StreamingReader.Window, startIndex: Long): Long { in findNewlineInWindow()32 fun StreamingReader.iterLines() = iterator { in <lambda>() method
21 class StreamingReader(val source: BufferProducer, val keepLoadedSize: Int = 8096) : GenericByteBuff… class
47 StreamingReader(readFile(file)).iterLines().forEach { in testLineReaderOnFile()