public class BooleanAsyncBuilder
extends java.lang.Object
public void processFiles(ObjectCollection<String> potentialFiles) {
potentialFiles.asAsync()
.map(Paths::get).filter(Files::exists) //Modifies the collection (Optional)
.forEach(Files::delete) //Creates the action (Required)
.onCompletion(T -> {}} //Callback on completion (Optional)
.execute() //Starts the task. (Required)
}
| Modifier and Type | Class and Description |
|---|---|
static class |
BooleanAsyncBuilder.BaseBooleanTask
Base Task of the Actions that can be performed.
|
| Constructor and Description |
|---|
BooleanAsyncBuilder(BooleanAsyncBuilder.BaseBooleanTask task)
Helper constructor.
|
BooleanAsyncBuilder(BooleanIterable iterable)
Main Constructor that uses a Iterable to build a Offthread Task.
|
| Modifier and Type | Method and Description |
|---|---|
<E> ObjectAsyncBuilder<E> |
arrayflatMap(BooleanFunction<E[]> mapper)
Maps the elements to something else
|
IntAsyncBuilder |
count(BooleanPredicate filter)
Counts all desired elements inside the Iterable
|
BooleanAsyncBuilder |
distinct()
Removes duplicated elements out of the Iterable
|
BooleanTask |
execute()
Starts the Execution of the task without awaiting its result
|
BooleanAsyncBuilder |
executor(java.util.concurrent.Executor executor)
Optional way to add a custom executor that runs this offthread task.
|
BooleanAsyncBuilder |
filter(BooleanPredicate filter)
Filters out the unwanted elements out of the Iterable
|
BooleanAsyncBuilder |
findFirst(BooleanPredicate filter)
Searches through the elements of the Iterable to find if the desired element.
|
<E,V extends java.lang.Iterable<E>> |
flatMap(BooleanFunction<V> mapper)
Maps the elements to something else
|
ObjectAsyncBuilder<java.lang.Void> |
forEach(BooleanConsumer action)
Iterates over the Iterable with a desired action
|
boolean |
join()
Starts the Execution of the task and will await its completion, returning the result.
|
boolean |
join(long timeout,
java.util.concurrent.TimeUnit unit)
Starts the Execution of the task and will await its completion with a timeout, returning the result.
|
BooleanAsyncBuilder |
limit(long limit)
Limits how many elements are inside of the Iterable
|
<E> ObjectAsyncBuilder<E> |
map(BooleanFunction<E> mapper)
Maps the elements to something else
|
BooleanAsyncBuilder |
matchAll(BooleanPredicate filter)
Searches through the elements of the Iterable to find if all the desired elements are present.
|
BooleanAsyncBuilder |
matchAny(BooleanPredicate filter)
Searches through the elements of the Iterable to find if the desired element is present.
|
BooleanAsyncBuilder |
matchNone(BooleanPredicate filter)
Searches through the elements of the Iterable to find if unwanted elements are present.
|
static BooleanAsyncBuilder |
of(boolean... values)
Helper function that automatically wraps a array into a AsyncBuilder since it forces this collections Iterable.
|
static BooleanAsyncBuilder |
of(java.lang.Iterable<java.lang.Boolean> iterable)
Helper function that automatically wraps a Iterable into a AsyncBuilder since it forces this collections Iterable.
|
BooleanAsyncBuilder |
onCompletion(java.util.function.Consumer<BooleanTask> callback)
Optional way to set a callback that allows to compute actions after the task was completed.
|
BooleanAsyncBuilder |
peek(BooleanConsumer action)
Allows to preview elements before they are processed
|
<E extends BooleanCollection> |
pour(E collection)
Pours all elements into a collection that can be later
|
ObjectAsyncBuilder<BooleanList> |
pourAsList()
Pours all elements into a List that can be later
|
BooleanAsyncBuilder |
reduce(boolean identity,
BooleanBooleanUnaryOperator operator)
Reduces the elements inside of the Iterable down to one element using a identity element.
|
BooleanAsyncBuilder |
reduce(BooleanBooleanUnaryOperator operator)
Reduces the elements inside of the Iterable down to one element
|
BooleanAsyncBuilder |
repeat(int repeats)
Repeats the elements inside of the Iterable
|
BooleanAsyncBuilder |
sorted(BooleanComparator sorter)
Sorts the elements inside of the Iterable.
|
ObjectAsyncBuilder<boolean[]> |
toBooleanArray()
Pours all elements of the Iterable down into a Array.
|
public BooleanAsyncBuilder(BooleanIterable iterable)
iterable - that should be processedpublic BooleanAsyncBuilder(BooleanAsyncBuilder.BaseBooleanTask task)
task - that had been buildpublic static BooleanAsyncBuilder of(java.lang.Iterable<java.lang.Boolean> iterable)
iterable - that should be wrappedpublic static BooleanAsyncBuilder of(boolean... values)
values - that should be wrappedpublic <E> ObjectAsyncBuilder<E> map(BooleanFunction<E> mapper)
E - The return type.mapper - the mapping functionpublic <E,V extends java.lang.Iterable<E>> ObjectAsyncBuilder<E> flatMap(BooleanFunction<V> mapper)
V - The return type supplier.E - The return type.mapper - the flatMapping functionpublic <E> ObjectAsyncBuilder<E> arrayflatMap(BooleanFunction<E[]> mapper)
E - The return type.mapper - the flatMapping functionpublic BooleanAsyncBuilder filter(BooleanPredicate filter)
filter - the elements that should be keptpublic BooleanAsyncBuilder distinct()
public BooleanAsyncBuilder repeat(int repeats)
repeats - the amount of times the elements should be repeatedpublic BooleanAsyncBuilder limit(long limit)
limit - how many elements should max be iterated throughpublic BooleanAsyncBuilder sorted(BooleanComparator sorter)
sorter - that sorts the elements.public BooleanAsyncBuilder peek(BooleanConsumer action)
action - the action that should be appliedpublic ObjectAsyncBuilder<java.lang.Void> forEach(BooleanConsumer action)
action - that should be appliedpublic BooleanAsyncBuilder reduce(BooleanBooleanUnaryOperator operator)
operator - that reduces the elements.public BooleanAsyncBuilder reduce(boolean identity, BooleanBooleanUnaryOperator operator)
identity - the element the reduce function should start withoperator - that reduces the elements.public ObjectAsyncBuilder<boolean[]> toBooleanArray()
public ObjectAsyncBuilder<BooleanList> pourAsList()
public <E extends BooleanCollection> ObjectAsyncBuilder<E> pour(E collection)
E - the return typecollection - the collection the elementspublic BooleanAsyncBuilder matchAny(BooleanPredicate filter)
filter - that decides the desired elementspublic BooleanAsyncBuilder matchNone(BooleanPredicate filter)
filter - that decides the unwanted elementspublic BooleanAsyncBuilder matchAll(BooleanPredicate filter)
filter - that decides the desired elementspublic BooleanAsyncBuilder findFirst(BooleanPredicate filter)
filter - that decides the desired elementspublic IntAsyncBuilder count(BooleanPredicate filter)
filter - that decides the desired elementspublic BooleanAsyncBuilder executor(java.util.concurrent.Executor executor)
executor - that executes the task, defaults to SanityChecks.invokeAsyncTask(Runnable)public BooleanAsyncBuilder onCompletion(java.util.function.Consumer<BooleanTask> callback)
callback - that should be notified after completion of the taskpublic BooleanTask execute()
public boolean join()
throws java.util.concurrent.ExecutionException,
java.lang.InterruptedException
java.util.concurrent.ExecutionException - if the task threw a exceptionjava.lang.InterruptedException - if the caller thread was interruptedpublic boolean join(long timeout,
java.util.concurrent.TimeUnit unit)
throws java.lang.InterruptedException,
java.util.concurrent.ExecutionException,
java.util.concurrent.TimeoutException
timeout - of how long the thread should wait the task to be completedunit - of the desired waiting time.java.lang.InterruptedException - if the caller thread was interruptedjava.util.concurrent.ExecutionException - if the task threw a exceptionjava.util.concurrent.TimeoutException - if the timeout was reached before the task was finished