Searched refs:BufferProducer (Results 1 – 15 of 15) sorted by relevance
22 import trebuchet.io.BufferProducer33 fun import(source: BufferProducer): Model { in import()38 private fun extractOrImport(stream: BufferProducer) { in extractOrImport()
23 import trebuchet.io.BufferProducer in <lambda>()87 fun readFile(file: File): BufferProducer { in <lambda>()89 return object : BufferProducer { in <lambda>()
19 import trebuchet.io.BufferProducer34 fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit)
28 override fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit) { in <lambda>()59 private class SubStream(val pipe: Pipe<DataSlice>) : BufferProducer { in <lambda>()
43 : BufferProducer {89 override fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit) { in extract()
19 import trebuchet.io.BufferProducer26 return StreamingReader(object : BufferProducer { in makeReader()
21 import trebuchet.io.BufferProducer30 return task.import(object : BufferProducer { in parseString()
19 import trebuchet.io.BufferProducer28 val progressCallback: ProgressCallback? = null) : BufferProducer {
69 fun readFile(file: File): BufferProducer { in readFile()71 return object : BufferProducer { in readFile()
23 import trebuchet.io.BufferProducer67 private fun openSample(name: String = "missed_traces.trace"): BufferProducer { in openSample()
21 import trebuchet.io.BufferProducer in <lambda>()89 return StreamingReader(object : BufferProducer { in <lambda>()
21 import trebuchet.io.BufferProducer in <lambda>()72 val model = task.import(object : BufferProducer { in <lambda>()
21 import trebuchet.io.BufferProducer in <lambda>()39 fun findTraces(stream: BufferProducer, in findTraces()
19 interface BufferProducer { interface
21 class StreamingReader(val source: BufferProducer, val keepLoadedSize: Int = 8096) : GenericByteBuff…