Searched refs:Consumer (Results 51 - 75 of 240) sorted by relevance

12345678910

/openjdk9/jdk/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DWhileOpStatefulTest.java33 import java.util.function.Consumer;
216 private void testTakeWhileMulti(Consumer<Stream<Integer>> mRef,
217 Consumer<IntStream> mInt,
218 Consumer<LongStream> mLong,
219 Consumer<DoubleStream> mDouble) {
227 private void testDropWhileMulti(Consumer<Stream<Integer>> mRef,
228 Consumer<IntStream> mInt,
229 Consumer<LongStream> mLong,
230 Consumer<DoubleStream> mDouble) {
249 Consumer<Strea
[all...]
/openjdk9/hotspot/src/jdk.internal.vm.compiler/share/classes/org.graalvm.compiler.lir/src/org/graalvm/compiler/lir/constopt/
H A DDefUseTree.java27 import java.util.function.Consumer;
81 public void forEach(Consumer<? super UseEntry> action) {
H A DVariableMap.java26 import java.util.function.Consumer;
68 public void forEach(Consumer<T> action) {
/openjdk9/jaxp/test/javax/xml/jaxp/unittest/stream/XMLStreamReaderTest/
H A DIssueTracker70.java28 import java.util.function.Consumer;
60 private void testGetAttributeValueWithNs(String nameSpace, String attrName, Consumer<String> checker) throws Exception {
/openjdk9/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/
H A DPushPublisher.java30 import java.util.function.Consumer;
67 public Consumer<Optional<T>> asDataConsumer() {
/openjdk9/jdk/test/javax/imageio/spi/
H A DServiceRegistryRestriction.java33 import java.util.function.Consumer;
55 <T> void doOneTest(String label, Class<T> clazz, boolean expectFail, Consumer<Class<T>> op) {
/openjdk9/jdk/src/jdk.editpad/share/classes/jdk/editpad/
H A DEditPad.java37 import java.util.function.Consumer;
53 private final Consumer<String> errorHandler;
56 private final Consumer<String> saveHandler;
67 EditPad(String windowLabel, Consumer<String> errorHandler, String initialText,
68 Runnable closeMark, Consumer<String> saveHandler) {
/openjdk9/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/common/
H A DAsyncDataReadQueue.java36 import java.util.function.Consumer;
39 * Http2Frame Producer-Consumer queue which either allows to consume all frames in blocking way
67 private Consumer<Throwable> onError;
87 public void blockingReceive(DataConsumer onData, Consumer<Throwable> onError) {
102 Consumer<Throwable> onError) {
132 private static <T> boolean checkCanSet(String name, T oldval, Consumer<Throwable> onError) {
/openjdk9/nashorn/src/jdk.scripting.nashorn.shell/share/classes/jdk/nashorn/tools/jjs/
H A DHistoryObject.java36 import java.util.function.Consumer;
65 private final Consumer<String> evaluator;
68 final Consumer<String> evaluator) {
110 return (Consumer<Object>)this::load;
114 return (Consumer<Object>)this::save;
/openjdk9/jdk/src/java.base/share/classes/java/time/format/
H A DDateTimeParseContext.java73 import java.util.function.Consumer;
113 private ArrayList<Consumer<Chronology>> chronoListeners = null;
386 Consumer<Chronology>[] tmp = new Consumer[1];
387 Consumer<Chronology>[] listeners = chronoListeners.toArray(tmp);
389 for (Consumer<Chronology> l : listeners) {
396 * Adds a Consumer<Chronology> to the list of listeners to be notified
398 * @param listener a Consumer<Chronology> to be called when Chronology changes
400 void addChronoChangedListener(Consumer<Chronology> listener) {
/openjdk9/jdk/src/java.base/share/classes/java/util/concurrent/
H A DCompletionStage.java40 import java.util.function.Consumer;
54 * Function, Consumer, or Runnable (using methods with names including
219 public CompletionStage<Void> thenAccept(Consumer<? super T> action);
234 public CompletionStage<Void> thenAcceptAsync(Consumer<? super T> action);
249 public CompletionStage<Void> thenAcceptAsync(Consumer<? super T> action,
532 Consumer<? super T> action);
550 Consumer<? super T> action);
569 Consumer<? super T> action,
/openjdk9/hotspot/test/gc/g1/humongousObjects/objectGraphTest/
H A DObjectGraph.java33 import java.util.function.Consumer;
54 public static void propagateTransitiveProperty(Set<Object[]> nodes, Consumer<Object[]> operation) {
130 Consumer<Object[]> markVertex) {
/openjdk9/langtools/test/jdk/jshell/
H A DJShellStateClosedTest.java31 import java.util.function.Consumer;
99 private void testStateClosedException(Consumer<Snippet> action) {
110 private void testStateClosedWithoutException(Consumer<Snippet> action) {
H A DMyExecutionControl.java36 import java.util.function.Consumer;
86 List<Consumer<String>> deathListeners = new ArrayList<>();
89 for (Consumer<String> h : deathListeners) {
121 List<Consumer<String>> deathListeners) {
/openjdk9/langtools/src/jdk.jshell/share/classes/jdk/jshell/execution/
H A DRemoteExecutionControl.java35 import java.util.function.Consumer;
65 Map<String, Consumer<OutputStream>> outputs = new HashMap<>();
68 Map<String, Consumer<InputStream>> input = new HashMap<>();
/openjdk9/langtools/src/jdk.jshell/share/classes/jdk/internal/jshell/tool/
H A DStopDetectingInputStream.java30 import java.util.function.Consumer;
36 private final Consumer<Exception> errorHandler;
44 public StopDetectingInputStream(Runnable stop, Consumer<Exception> errorHandler) {
/openjdk9/jdk/test/java/util/stream/test/org/openjdk/tests/java/lang/invoke/
H A DSerializedLambdaTest.java41 import java.util.function.Consumer;
62 private<T> void assertSerial(T p, Consumer<T> asserter) throws IOException, ClassNotFoundException {
73 private void assertNotSerial(Predicate<String> p, Consumer<Predicate<String>> asserter)
197 Consumer<Predicate<String>> b = p -> {
215 Consumer<BiPredicate<Moo, String>> b = p -> {
235 Consumer<Predicate<String>> b = p -> {
258 Consumer<Predicate<String>> b = p -> {
276 Consumer<Supplier<ForCtorRef>> b = s -> {
288 Consumer<String> c = (Consumer<Strin
[all...]
/openjdk9/jdk/test/java/util/concurrent/LinkedTransferQueue/
H A DSpliteratorTraverseAddRemoveTest.java45 import java.util.function.Consumer;
50 static Object[] of(String desc, Consumer<Queue<?>> c) {
88 public void testQueue(String desc, Consumer<Queue<String>> c)
/openjdk9/jdk/test/java/util/concurrent/ConcurrentLinkedQueue/
H A DWhiteBox.java57 import java.util.function.Consumer;
119 return List.<Consumer<ConcurrentLinkedQueue>>of(
132 Consumer<ConcurrentLinkedQueue> traversalAction) {
170 Consumer<ConcurrentLinkedQueue> traversalAction) {
185 Consumer<ConcurrentLinkedQueue> traversalAction) {
215 Consumer<ConcurrentLinkedQueue> traversalAction) {
238 return List.<Consumer<ConcurrentLinkedQueue>>of(
247 Consumer<ConcurrentLinkedQueue> bulkRemovalAction) {
262 return List.<Consumer<ConcurrentLinkedQueue>>of(
270 Consumer<ConcurrentLinkedQueu
[all...]
/openjdk9/jdk/test/java/net/httpclient/http2/jdk.incubator.httpclient/jdk/incubator/http/internal/hpack/
H A DBuffersTestingKit.java27 import java.util.function.Consumer;
159 Consumer<? super Iterable<? extends ByteBuffer>> action) {
175 private static void forEachSplit(int n, Consumer<? super Iterable<? extends Integer>> action) {
180 Consumer<? super Iterable<? extends Integer>> action) {
/openjdk9/langtools/test/tools/javac/generics/inference/8152832/
H A DT8152832.java48 public static <T> void myStream(Supplier<Stream<T>> base, Consumer<MyStreamSupplier<T>> consumer) {
/openjdk9/jdk/test/sun/management/jmxremote/startstop/
H A DManagementAgentJcmd.java30 import java.util.function.Consumer;
140 public String start(Consumer<String> c, String ... params) throws IOException, InterruptedException {
170 * @param c {@linkplain Consumer} instance
176 private String jcmd(Consumer<String> c, String ... command) throws IOException, InterruptedException {
184 * @param c {@linkplain Consumer} instance
190 private String jcmd(String target, final Consumer<String> c, String ... command) throws IOException, InterruptedException {
/openjdk9/jdk/src/java.base/share/classes/java/util/stream/
H A DStream.java40 import java.util.function.Consumer;
80 * as {@link Stream#count()} or {@link Stream#forEach(Consumer)}).
441 Stream<T> peek(Consumer<? super T> action);
647 void forEach(Consumer<? super T> action);
664 * @see #forEach(Consumer)
666 void forEachOrdered(Consumer<? super T> action);
1221 public boolean tryAdvance(Consumer<? super T> action) {
1284 public boolean tryAdvance(Consumer<? super T> action) {
1305 public void forEachRemaining(Consumer<? super T> action) {
1385 public interface Builder<T> extends Consumer<
[all...]
/openjdk9/hotspot/test/compiler/compilercontrol/share/processors/
H A DCommandProcessor.java32 import java.util.function.Consumer;
37 public class CommandProcessor implements Consumer<OutputAnalyzer> {
/openjdk9/jdk/test/java/awt/datatransfer/DataFlavor/
H A DDataFlavorRemoteTest.java58 .executeChildProcess(Consumer.class, new String[0]);
65 static class Consumer { class in class:DataFlavorRemoteTest

Completed in 298 milliseconds

12345678910