| 程序包 | 说明 |
|---|---|
| com.jn.langx.io.resource | |
| com.jn.langx.util.collection |
many collection utility class
|
| com.jn.langx.util.concurrent.completion | |
| com.jn.langx.util.io |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
Resources.readLines(String location,
Charset charset,
Consumer<String> consumer) |
static void |
Resources.readUsingDelimiter(byte[] byteArray,
String delimiter,
Charset charset,
Consumer<String> consumer) |
static void |
Resources.readUsingDelimiter(Resource resource,
String delimiter,
Charset charset,
Consumer<String> consumer) |
static void |
Resources.readUsingDelimiter(Resource resource,
String delimiter,
Consumer<byte[]> consumer) |
static void |
Resources.readUsingDelimiter(String location,
String delimiter,
Charset charset,
Consumer<String> consumer) |
static void |
Resources.readUsingDelimiter(URL url,
String delimiter,
Charset charset,
Consumer<String> consumer) |
| 限定符和类型 | 方法和说明 |
|---|---|
static <E,C extends Iterable<E>> |
Collects.forEach(C collection,
Consumer<E> consumer) |
static <E,C extends Iterable<E>> |
Collects.forEach(C collection,
Consumer<E> consumer,
Predicate<E> breakPredicate) |
void |
Pipeline.forEach(Consumer<E> consumer) |
void |
Pipeline.forEach(Consumer<E> consumer,
Predicate<E> breakPredicate) |
static <E,C extends Iterable<E>> |
Collects.forEach(C collection,
Predicate<E> consumePredicate,
Consumer<E> consumer) |
static <E,C extends Iterable<E>> |
Collects.forEach(C collection,
Predicate<E> consumePredicate,
Consumer<E> consumer,
Predicate<E> breakPredicate)
Consume every element what matched the consumePredicate
|
static <E> void |
Collects.forEach(E[] array,
Consumer<E> consumer) |
static <E> void |
Collects.forEach(E[] array,
Predicate<E> consumePredicate,
Consumer<E> consumer,
Predicate<E> breakPredicate)
consume every element that matched the consumePredicate
|
void |
Pipeline.forEach(Predicate<E> consumePredicate,
Consumer<E> consumer,
Predicate<E> breakPredicate) |
| 限定符和类型 | 方法和说明 |
|---|---|
CompletionStep<Void> |
CompletionStep.acceptEither(CompletionStep<? 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<Void> |
CompletableFuture.acceptEither(CompletionStep<? extends T> other,
Consumer<? super T> action) |
CompletionStep<Void> |
CompletionStep.acceptEitherAsync(CompletionStep<? 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.
|
CompletableFuture<Void> |
CompletableFuture.acceptEitherAsync(CompletionStep<? extends T> other,
Consumer<? super T> action) |
CompletionStep<Void> |
CompletionStep.acceptEitherAsync(CompletionStep<? 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.
|
CompletableFuture<Void> |
CompletableFuture.acceptEitherAsync(CompletionStep<? extends T> other,
Consumer<? super T> action,
Executor executor) |
CompletionStep<Void> |
CompletionStep.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<Void> |
CompletableFuture.thenAccept(Consumer<? super T> action) |
CompletionStep<Void> |
CompletionStep.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.
|
CompletableFuture<Void> |
CompletableFuture.thenAcceptAsync(Consumer<? super T> action) |
CompletionStep<Void> |
CompletionStep.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.
|
CompletableFuture<Void> |
CompletableFuture.thenAcceptAsync(Consumer<? super T> action,
Executor executor) |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
Channels.readLines(InputStream inputStream,
Charset charset,
Consumer<String> consumer) |
static void |
Channels.readLines(InputStream inputStream,
Consumer<String> consumer) |
static void |
Channels.readLines(ReadableByteChannel channel,
Charset charset,
Consumer<String> consumer) |
static void |
Channels.readLines(ReadableByteChannel channel,
Consumer<String> consumer) |
static void |
Channels.readUsingDelimiter(InputStream inputStream,
String delimiter,
Charset charset,
Consumer<String> consumer) |
static void |
Channels.readUsingDelimiter(InputStream inputStream,
String delimiter,
Consumer<byte[]> consumer) |
static void |
Channels.readUsingDelimiter(ReadableByteChannel channel,
String delimiter,
Charset charset,
Consumer<String> consumer) |
static void |
Channels.readUsingDelimiter(ReadableByteChannel channel,
String delimiter,
Consumer<byte[]> consumer) |
Copyright © 2020. All rights reserved.