Lines Matching defs:forward
28 private BlockingDeque<String> forward;
39 forward = new ForwardingBlockingDeque<String>() {
47 forward.remainingCapacity();
52 forward.putFirst("asf");
57 forward.putFirst("asf");
62 forward.offerFirst("asf", 2L, TimeUnit.SECONDS);
67 forward.offerLast("asf", 2L, TimeUnit.SECONDS);
72 forward.takeFirst();
77 forward.takeLast();
82 forward.pollFirst(2L, TimeUnit.SECONDS);
87 forward.pollLast(2L, TimeUnit.SECONDS);
92 forward.put("asf");
97 forward.offer("asf", 2L, TimeUnit.SECONDS);
102 forward.take();
107 forward.poll(2L, TimeUnit.SECONDS);
112 forward.drainTo(Lists.newArrayList());
117 forward.drainTo(Lists.newArrayList(), 3);
