HomeSort by relevance Sort by last modified time
    Searched refs:drainTo (Results 1 - 21 of 21) sorted by null

  /external/grpc-grpc-java/core/src/main/java/io/grpc/
Drainable.java 39 int drainTo(OutputStream target) throws IOException;
  /external/guava/guava/src/com/google/common/util/concurrent/
ForwardingBlockingQueue.java 44 @Override public int drainTo(
46 return delegate().drainTo(c, maxElements);
49 @Override public int drainTo(Collection<? super E> c) {
50 return delegate().drainTo(c);
  /external/guava/guava/src/com/google/common/collect/
ForwardingBlockingDeque.java 115 public int drainTo(Collection<? super E> c) {
116 return delegate().drainTo(c);
120 public int drainTo(Collection<? super E> c, int maxElements) {
121 return delegate().drainTo(c, maxElements);
Queues.java 247 * Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested
265 * execute Queue#drainTo is not added *on top* of waiting for the timeout (which could make
271 // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple
272 // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
273 added += q.drainTo(buffer, numElements - added);
308 // we could rely solely on #poll, but #drainTo might be more efficient when there are
309 // multiple elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
310 added += q.drainTo(buffer, numElements - added);
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/
ByteBufInputStream.java 40 public int drainTo(OutputStream target) throws IOException {
  /external/guava/guava-tests/test/com/google/common/collect/
ForwardingBlockingDequeTest.java 112 forward.drainTo(Lists.newArrayList());
113 assertEquals("[drainTo(Collection)]", getCalls());
117 forward.drainTo(Lists.newArrayList(), 3);
118 assertEquals("[drainTo(Collection,int)]", getCalls());
  /external/grpc-grpc-java/protobuf-lite/src/test/java/io/grpc/protobuf/lite/
ProtoLiteUtilsTest.java 158 int drained = d.drainTo(baos);
176 int drained = d.drainTo(baos);
188 assertEquals(0, d.drainTo(baos));
  /external/flatbuffers/grpc/flatbuffers-java-grpc/src/main/java/com/google/flatbuffers/grpc/
FlatbuffersUtils.java 62 public int drainTo(OutputStream target) throws IOException {
  /external/grpc-grpc-java/protobuf-lite/src/main/java/io/grpc/protobuf/lite/
ProtoInputStream.java 48 public int drainTo(OutputStream target) throws IOException {
  /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
MonitorBasedPriorityBlockingQueue.java 52 * <tt>Arrays.sort(pq.toArray())</tt>. Also, method <tt>drainTo</tt>
395 public int drainTo(Collection<? super E> c) {
422 public int drainTo(Collection<? super E> c, int maxElements) {
MonitorBasedArrayBlockingQueue.java 593 public int drainTo(Collection<? super E> c) {
629 public int drainTo(Collection<? super E> c, int maxElements) {
  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
MessageFramer.java 268 return ((Drainable) message).drainTo(outputStream);
  /cts/tests/tests/os/src/android/os/cts/
StrictModeTest.java 623 binderHolder.drainTo(new ArrayList<>());
  /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
AbstractTransportTest.java     [all...]
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 
  /external/cldr/tools/java/libs/
guava.jar 
  /external/dagger2/lib/
google-java-format-0.1-20151017.042846-2.jar 
  /external/guice/lib/
guava-19.0.jar 
  /external/owasp/sanitizer/distrib/lib/
guava.jar 
  /external/owasp/sanitizer/lib/guava-libraries/
guava.jar 
  /external/testng/ant/3rdparty/
doclava-1.0.3.jar 

Completed in 849 milliseconds