Package | Description |
---|---|
org.apache.commons.io |
Provides classes for working with streams, readers, writers and files.
|
org.apache.commons.io.function |
Provides IO-only related functional interfaces for lambda expressions and method references.
|
org.apache.commons.io.input |
Provides implementations of input classes, such as
InputStream and Reader . |
org.apache.commons.io.output |
Provides implementations of output classes, such as
OutputStream and
Writer . |
Modifier and Type | Method and Description |
---|---|
static void |
IOUtils.close(java.io.Closeable closeable,
IOConsumer<java.io.IOException> consumer)
Closes the given
Closeable as a null-safe operation. |
Modifier and Type | Field and Description |
---|---|
static IOConsumer<?> |
IOConsumer.NOOP_IO_CONSUMER
Consider private.
|
Modifier and Type | Method and Description |
---|---|
default IOConsumer<T> |
IOFunction.andThen(java.util.function.Consumer<? super R> after)
Returns a composed
IOFunction that first applies this function to its input, and then applies the
after consumer to the result. |
default IOConsumer<T> |
IOFunction.andThen(IOConsumer<? super R> after)
Returns a composed
IOFunction that first applies this function to its input, and then applies the
after consumer to the result. |
default IOConsumer<T> |
IOConsumer.andThen(IOConsumer<? super T> after)
Returns a composed
IOConsumer that performs, in sequence, this operation followed by the after
operation. |
static <T> IOConsumer<T> |
IOConsumer.noop()
Returns the constant no-op consumer.
|
(package private) static <T> IOConsumer<T> |
IOStreams.toIOConsumer(IOConsumer<T> action) |
Modifier and Type | Method and Description |
---|---|
(package private) static <T> void |
Erase.accept(IOConsumer<T> consumer,
T t)
Delegates to the given
IOConsumer but erases its IOException for the compiler, while still throwing
the exception at runtime. |
static <T> void |
Uncheck.accept(IOConsumer<T> consumer,
T t)
Accepts an IO consumer with the given argument.
|
default IOConsumer<T> |
IOFunction.andThen(IOConsumer<? super R> after)
Returns a composed
IOFunction that first applies this function to its input, and then applies the
after consumer to the result. |
default IOConsumer<T> |
IOConsumer.andThen(IOConsumer<? super T> after)
Returns a composed
IOConsumer that performs, in sequence, this operation followed by the after
operation. |
default void |
IOStream.forAll(IOConsumer<T> action)
Performs an action for each element gathering any exceptions.
|
default void |
IOStream.forAll(IOConsumer<T> action,
java.util.function.BiFunction<java.lang.Integer,java.io.IOException,java.io.IOException> exSupplier)
Performs an action for each element gathering any exceptions.
|
static <T> void |
IOConsumer.forAll(IOConsumer<T> action,
java.lang.Iterable<T> iterable)
Performs an action for each element of the collection gathering any exceptions.
|
static <T> void |
IOConsumer.forAll(IOConsumer<T> action,
java.util.stream.Stream<T> stream)
Performs an action for each element of the collection gathering any exceptions.
|
static <T> void |
IOConsumer.forAll(IOConsumer<T> action,
T... array)
Performs an action for each element of the array gathering any exceptions.
|
(package private) static <T> void |
IOStreams.forAll(java.util.stream.Stream<T> stream,
IOConsumer<T> action) |
(package private) static <T> void |
IOStreams.forAll(java.util.stream.Stream<T> stream,
IOConsumer<T> action,
java.util.function.BiFunction<java.lang.Integer,java.io.IOException,java.io.IOException> exSupplier) |
default void |
IOStream.forEach(IOConsumer<? super T> action)
Like
Stream.forEach(java.util.function.Consumer) but throws IOException . |
static <T> void |
IOConsumer.forEach(java.lang.Iterable<T> iterable,
IOConsumer<T> action)
Performs an action for each element of the collection, stopping at the first exception.
|
static <T> void |
IOConsumer.forEach(java.util.stream.Stream<T> stream,
IOConsumer<T> action)
Performs an action for each element of the stream, stopping at the first exception.
|
(package private) static <T> void |
IOStreams.forEach(java.util.stream.Stream<T> stream,
IOConsumer<T> action) |
static <T> void |
IOConsumer.forEach(T[] array,
IOConsumer<T> action)
Performs an action for each element of this array, stopping at the first exception.
|
default void |
IOStream.forEachOrdered(IOConsumer<? super T> action)
Like
Stream.forEachOrdered(java.util.function.Consumer) . |
default void |
IOIterator.forEachRemaining(IOConsumer<? super E> action)
Like
Iterator.forEachRemaining(Consumer) . |
default void |
IOSpliterator.forEachRemaining(IOConsumer<? super T> action)
Like
Spliterator.forEachRemaining(Consumer) . |
default IOStream<T> |
IOStream.peek(IOConsumer<? super T> action)
Like
Stream.peek(java.util.function.Consumer) . |
(package private) static <T> IOConsumer<T> |
IOStreams.toIOConsumer(IOConsumer<T> action) |
default boolean |
IOSpliterator.tryAdvance(IOConsumer<? super T> action)
Like
Spliterator.tryAdvance(Consumer) . |
Modifier and Type | Method and Description |
---|---|
private void |
ObservableInputStream.forEachObserver(IOConsumer<ObservableInputStream.Observer> action) |
Modifier and Type | Field and Description |
---|---|
private IOConsumer<ThresholdingOutputStream> |
ThresholdingOutputStream.thresholdConsumer
Accepts reaching the threshold.
|
Modifier and Type | Method and Description |
---|---|
private FilterCollectionWriter |
FilterCollectionWriter.forAllWriters(IOConsumer<java.io.Writer> action) |
Constructor and Description |
---|
ThresholdingOutputStream(int threshold,
IOConsumer<ThresholdingOutputStream> thresholdConsumer,
IOFunction<ThresholdingOutputStream,java.io.OutputStream> outputStreamGetter)
Constructs an instance of this class which will trigger an event at the specified threshold.
|