Searched refs:StreamItem (Results 1 – 3 of 3) sorted by relevance
24 import com.google.caliper.runner.StreamService.StreamItem.Kind;83 private static final StreamItem TIMEOUT_ITEM = new StreamItem(Kind.TIMEOUT, null);86 static final StreamItem EOF_ITEM = new StreamItem(Kind.EOF, null);90 private final BlockingQueue<StreamItem> outputQueue = Queues.newLinkedBlockingQueue();194 StreamItem readItem(long timeout, TimeUnit unit) throws InterruptedException { in readItem()196 StreamItem line = outputQueue.poll(timeout, unit); in readItem()291 static class StreamItem { class in StreamService304 private StreamItem(LogMessage line) { in StreamItem() method in StreamService.StreamItem308 private StreamItem(Kind state, @Nullable LogMessage logMessage) { in StreamItem() method in StreamService.StreamItem324 ToStringHelper helper = MoreObjects.toStringHelper(StreamItem.class); in toString()[all …]
26 import com.google.caliper.runner.StreamService.StreamItem;91 StreamItem item; in call()
27 import com.google.caliper.runner.StreamService.StreamItem;28 import com.google.caliper.runner.StreamService.StreamItem.Kind;94 StreamItem item1 = readItem(); in testReadOutput()98 StreamItem item2 = readItem(); in testReadOutput()103 StreamItem item3 = readItem(); in testReadOutput()137 StreamItem nextItem = readItem(); in testSocketInputOutput()172 private StreamItem readItem() throws InterruptedException { in readItem()173 StreamItem item = service.readItem(10, TimeUnit.SECONDS); in readItem()