Uses of Interface
java.util.function.Consumer
Package
Description
Provides classes that are fundamental to the design of the Java
programming language.
HTTP Client and WebSocket APIs
Defines channels, which represent connections to entities that are capable of
performing I/O operations, such as files and sockets; defines selectors, for
multiplexed, non-blocking I/O operations.
Contains the collections framework, some internationalization support classes,
a service loader, properties, random number generation, string parsing
and scanning classes, base64 encoding and decoding, a bit array, and
several miscellaneous utility classes.
Utility classes commonly useful in concurrent programming.
Functional interfaces provide target types for lambda expressions
and method references.
Classes to support functional-style operations on streams of elements, such
as map-reduce transformations on collections.
Classes to support low-level and efficient foreign memory/function access, directly from Java.
This package contains classes for consuming Flight Recorder data.
Provides interfaces for creating tools, such as a Read-Eval-Print Loop (REPL),
which interactively evaluate "snippets" of Java programming language code.
Provides implementation support for building JShell execution engines.
This package contains classes to control and monitor Flight Recorder over Java Management Extensions (JMX).
-
Uses of Consumer in java.lang
Modifier and TypeMethodDescriptiondefault void
Performs the given action for each element of theIterable
until all elements have been processed or the action throws an exception.void
StackWalker.forEach(Consumer<? super StackWalker.StackFrame> action)
Performs the given action on each element ofStackFrame
stream of the current thread, traversing from the top frame of the stack, which is the method calling thisforEach
method. -
Uses of Consumer in java.net.http
Modifier and TypeMethodDescriptionstatic HttpResponse.BodyHandler<Void>
HttpResponse.BodyHandlers.ofByteArrayConsumer(Consumer<Optional<byte[]>> consumer)
Returns aBodyHandler<Void>
that returns aBodySubscriber
<Void>
obtained fromBodySubscribers.ofByteArrayConsumer(Consumer)
.static HttpResponse.BodySubscriber<Void>
HttpResponse.BodySubscribers.ofByteArrayConsumer(Consumer<Optional<byte[]>> consumer)
Returns aBodySubscriber
which provides the incoming body data to the provided Consumer ofOptional<byte[]>
. -
Uses of Consumer in java.nio.channels
Modifier and TypeMethodDescriptionint
Selector.select(Consumer<SelectionKey> action)
Selects and performs an action on the keys whose corresponding channels are ready for I/O operations.int
Selector.select(Consumer<SelectionKey> action, long timeout)
Selects and performs an action on the keys whose corresponding channels are ready for I/O operations.int
Selector.selectNow(Consumer<SelectionKey> action)
Selects and performs an action on the keys whose corresponding channels are ready for I/O operations. -
Uses of Consumer in java.util
Modifier and TypeMethodDescriptionvoid
void
void
void
default void
Iterator.forEachRemaining(Consumer<? super E> action)
Performs the given action for each remaining element until all elements have been processed or the action throws an exception.default void
PrimitiveIterator.OfDouble.forEachRemaining(Consumer<? super Double> action)
Performs the given action for each remaining element until all elements have been processed or the action throws an exception.default void
PrimitiveIterator.OfInt.forEachRemaining(Consumer<? super Integer> action)
Performs the given action for each remaining element until all elements have been processed or the action throws an exception.default void
PrimitiveIterator.OfLong.forEachRemaining(Consumer<? super Long> action)
Performs the given action for each remaining element until all elements have been processed or the action throws an exception.default void
Spliterator.forEachRemaining(Consumer<? super T> action)
Performs the given action for each remaining element, sequentially in the current thread, until all elements have been processed or the action throws an exception.default void
Spliterator.OfDouble.forEachRemaining(Consumer<? super Double> action)
Performs the given action for each remaining element, sequentially in the current thread, until all elements have been processed or the action throws an exception.default void
Spliterator.OfInt.forEachRemaining(Consumer<? super Integer> action)
Performs the given action for each remaining element, sequentially in the current thread, until all elements have been processed or the action throws an exception.default void
Spliterator.OfLong.forEachRemaining(Consumer<? super Long> action)
Performs the given action for each remaining element, sequentially in the current thread, until all elements have been processed or the action throws an exception.void
If a value is present, performs the given action with the value, otherwise does nothing.void
Optional.ifPresentOrElse(Consumer<? super T> action, Runnable emptyAction)
If a value is present, performs the given action with the value, otherwise performs the given empty-based action.default boolean
Spliterator.OfDouble.tryAdvance(Consumer<? super Double> action)
If a remaining element exists, performs the given action on it, returningtrue
; else returnsfalse
.default boolean
Spliterator.OfInt.tryAdvance(Consumer<? super Integer> action)
If a remaining element exists, performs the given action on it, returningtrue
; else returnsfalse
.default boolean
Spliterator.OfLong.tryAdvance(Consumer<? super Long> action)
If a remaining element exists, performs the given action on it, returningtrue
; else returnsfalse
.boolean
Spliterator.tryAdvance(Consumer<? super T> action)
If a remaining element exists, performs the given action on it, returningtrue
; else returnsfalse
. -
Uses of Consumer in java.util.concurrent
Modifier and TypeMethodDescriptionCompletableFuture.acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)
CompletionStage.acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)
Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed with the corresponding result as argument to the supplied action.CompletableFuture.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action)
CompletableFuture.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
CompletionStage.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action)
Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using this stage's default asynchronous execution facility, with the corresponding result as argument to the supplied action.CompletionStage.acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
Returns a new CompletionStage that, when either this or the other given stage complete normally, is executed using the supplied executor, with the corresponding result as argument to the supplied action.Processes all published items using the given Consumer function.void
<U> void
ConcurrentHashMap.forEach(long parallelismThreshold, BiFunction<? super K,? super V,? extends U> transformer, Consumer<? super U> action)
Performs the given action for each non-null transformation of each (key, value).void
void
void
void
void
void
void
void
void
ConcurrentHashMap.forEachEntry(long parallelismThreshold, Consumer<? super Map.Entry<K,V>> action)
Performs the given action for each entry.<U> void
ConcurrentHashMap.forEachEntry(long parallelismThreshold, Function<Map.Entry<K,V>,? extends U> transformer, Consumer<? super U> action)
Performs the given action for each non-null transformation of each entry.void
ConcurrentHashMap.forEachKey(long parallelismThreshold, Consumer<? super K> action)
Performs the given action for each key.<U> void
ConcurrentHashMap.forEachKey(long parallelismThreshold, Function<? super K,? extends U> transformer, Consumer<? super U> action)
Performs the given action for each non-null transformation of each key.void
ConcurrentHashMap.forEachValue(long parallelismThreshold, Consumer<? super V> action)
Performs the given action for each value.<U> void
ConcurrentHashMap.forEachValue(long parallelismThreshold, Function<? super V,? extends U> transformer, Consumer<? super U> action)
Performs the given action for each non-null transformation of each value.CompletableFuture.thenAccept(Consumer<? super T> action)
CompletionStage.thenAccept(Consumer<? super T> action)
Returns a new CompletionStage that, when this stage completes normally, is executed with this stage's result as the argument to the supplied action.CompletableFuture.thenAcceptAsync(Consumer<? super T> action)
CompletableFuture.thenAcceptAsync(Consumer<? super T> action, Executor executor)
CompletionStage.thenAcceptAsync(Consumer<? super T> action)
Returns a new CompletionStage that, when this stage completes normally, is executed using this stage's default asynchronous execution facility, with this stage's result as the argument to the supplied action.CompletionStage.thenAcceptAsync(Consumer<? super T> action, Executor executor)
Returns a new CompletionStage that, when this stage completes normally, is executed using the supplied Executor, with this stage's result as the argument to the supplied action. -
Uses of Consumer in java.util.function
Modifier and TypeMethodDescriptionReturns a composedConsumer
that performs, in sequence, this operation followed by theafter
operation. -
Uses of Consumer in java.util.stream
Modifier and TypeInterfaceDescriptionstatic interface
A mutable builder for aStream
.Modifier and TypeMethodDescriptionvoid
Performs an action for each element of this stream.void
Stream.forEachOrdered(Consumer<? super T> action)
Performs an action for each element of this stream, in the encounter order of the stream if the stream has a defined encounter order.Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.Modifier and TypeMethodDescriptiondefault <R> Stream<R>
Stream.mapMulti(BiConsumer<? super T,? super Consumer<R>> mapper)
Returns a stream consisting of the results of replacing each element of this stream with multiple elements, specifically zero or more elements. -
Uses of Consumer in jdk.incubator.foreign
Modifier and TypeMethodDescriptionstatic CLinker.VaList
CLinker.VaList.make(Consumer<CLinker.VaList.Builder> actions)
Constructs a newVaList
using a builder (seeCLinker.VaList.Builder
).static CLinker.VaList
CLinker.VaList.make(Consumer<CLinker.VaList.Builder> actions, NativeScope scope)
Constructs a newVaList
using a builder (seeCLinker.VaList.Builder
). -
Uses of Consumer in jdk.jfr.consumer
Modifier and TypeMethodDescriptionvoid
Registers an action to perform if an exception occurs.void
void
EventStream.onEvent(String eventName, Consumer<RecordedEvent> action)
Registers an action to perform on all events matching a name.void
EventStream.onEvent(Consumer<RecordedEvent> action)
Registers an action to perform on all events in the stream.void
RecordingStream.onEvent(String eventName, Consumer<RecordedEvent> action)
void
RecordingStream.onEvent(Consumer<RecordedEvent> action)
default void
EventStream.onMetadata(Consumer<MetadataEvent> action)
Registers an action to perform when new metadata arrives in the stream. -
Uses of Consumer in jdk.jshell
Modifier and TypeMethodDescriptionJShell.onShutdown(Consumer<JShell> listener)
Register a callback to be called when this JShell instance terminates.JShell.onSnippetEvent(Consumer<SnippetEvent> listener)
Register a callback to be called when the Status of a snippet changes. -
Uses of Consumer in jdk.jshell.execution
Modifier and TypeMethodDescriptionstatic void
Util.detectJdiExitEvent(VirtualMachine vm, Consumer<String> unbiddenExitHandler)
Monitor the JDI event stream forVMDeathEvent
andVMDisconnectEvent
.Modifier and TypeMethodDescriptionstatic void
Util.forwardExecutionControlAndIO(ExecutionControl ec, InputStream inStream, OutputStream outStream, Map<String,Consumer<OutputStream>> outputStreamMap, Map<String,Consumer<InputStream>> inputStreamMap)
Forward commands from the input to the specifiedExecutionControl
instance, then responses back on the output. -
Uses of Consumer in jdk.management.jfr
Modifier and TypeMethodDescriptionvoid
void
RemoteRecordingStream.onEvent(String eventName, Consumer<RecordedEvent> action)
void
RemoteRecordingStream.onEvent(Consumer<RecordedEvent> action)