Searched refs:pipe (Results 1 – 2 of 2) sorted by relevance
38 val pipe = Pipe<DataSlice>() in <lambda>() constant40 stream.onWindowReleased = { window -> processWindow(window, pipe) } in <lambda>()46 stream.windows.forEach { processWindow(it, pipe) } in <lambda>()47 pipe.close() in <lambda>()51 processSubStream(SubStream(pipe)) in <lambda>()59 private class SubStream(val pipe: Pipe<DataSlice>) : BufferProducer { in <lambda>() constant in trebuchet.extractors.SystraceExtractor.SubStream60 override fun next(): DataSlice? = pipe.next() in <lambda>()63 private fun processWindow(window: StreamingReader.Window, pipe: Pipe<DataSlice>) { in <lambda>()66 pipe.add(window.slice) in <lambda>()70 pipe.add(window.slice.slice(sliceStart.toInt(), sliceEnd.toInt())) in <lambda>()
65 Separator(char end, char pipe, String text) { in Separator() argument67 mPipe = pipe; in Separator()219 public TableBuilder addSeparator(char end, char pipe) { in addSeparator() argument220 mTable.add(new Separator(end, pipe, "")); in addSeparator()