StateFuture<Void> |
AppendingState.asyncAdd(IN value) |
Updates the operator state accessible by AppendingState.asyncGet() by adding the given value to the
list of values asynchronously. |
StateFuture<Void> |
ListState.asyncAddAll(List<T> values) |
Updates the operator state accessible by AppendingState.asyncGet() by adding the given values to
existing list of values asynchronously. |
StateFuture<Void> |
State.asyncClear() |
Removes the value mapped under the current key asynchronously.
|
StateFuture<Boolean> |
MapState.asyncContains(UK key) |
Returns whether there exists the given mapping asynchronously.
|
StateFuture<StateIterator<Map.Entry<UK,UV>>> |
MapState.asyncEntries() |
Returns the current iterator for all the mappings of this state asynchronously.
|
StateFuture<OUT> |
AppendingState.asyncGet() |
Returns the current value for the state asynchronously.
|
StateFuture<UV> |
MapState.asyncGet(UK key) |
Returns the current value associated with the given key asynchronously.
|
StateFuture<Boolean> |
MapState.asyncIsEmpty() |
Returns whether this state contains no key-value mappings asynchronously.
|
StateFuture<StateIterator<UK>> |
MapState.asyncKeys() |
Returns the current iterator for all the keys of this state asynchronously.
|
StateFuture<Void> |
MapState.asyncPut(UK key,
UV value) |
Update the current value associated with the given key asynchronously.
|
StateFuture<Void> |
MapState.asyncPutAll(Map<UK,UV> map) |
Update all of the mappings from the given map into the state asynchronously.
|
StateFuture<Void> |
MapState.asyncRemove(UK key) |
Delete the mapping of the given key from the state asynchronously.
|
StateFuture<Void> |
ListState.asyncUpdate(List<T> values) |
Updates the operator state accessible by AppendingState.asyncGet() by updating existing values to
the given list of values asynchronously. |
StateFuture<Void> |
ValueState.asyncUpdate(T value) |
|
StateFuture<T> |
ValueState.asyncValue() |
Returns the current value for the state asynchronously.
|
StateFuture<StateIterator<UV>> |
MapState.asyncValues() |
Returns the current iterator for all the values of this state asynchronously.
|
<U> StateFuture<Collection<U>> |
StateIterator.onNext(FunctionWithException<T,StateFuture<? extends U>,Exception> iterating) |
Async iterate the data and call the callback when data is ready.
|
StateFuture<Void> |
StateIterator.onNext(ThrowingConsumer<T,Exception> iterating) |
Async iterate the data and call the callback when data is ready.
|
StateFuture<Void> |
StateFuture.thenAccept(ThrowingConsumer<? super T,? extends Exception> action) |
Returns a new StateFuture that, when this future completes normally, is executed with this
future's result as the argument to the supplied action.
|
<U> StateFuture<U> |
StateFuture.thenApply(FunctionWithException<? super T,? extends U,? extends Exception> fn) |
Returns a new StateFuture that, when this future completes normally, is executed with this
future's result as the argument to the supplied function.
|
<U,V>
StateFuture<V> |
StateFuture.thenCombine(StateFuture<? extends U> other,
BiFunctionWithException<? super T,? super U,? extends V,? extends Exception> fn) |
Returns a new StateFuture that, when this and the other given future both complete normally,
is executed with the two results as arguments to the supplied function.
|
<U> StateFuture<U> |
StateFuture.thenCompose(FunctionWithException<? super T,? extends StateFuture<U>,? extends Exception> action) |
Returns a new future that, when this future completes normally, is executed with this future
as the argument to the supplied function.
|
StateFuture<Boolean> |
StateFuture.thenConditionallyAccept(FunctionWithException<? super T,Boolean,? extends Exception> condition,
ThrowingConsumer<? super T,? extends Exception> actionIfTrue) |
Apply a condition test on the result of this StateFuture, and try to perform the action if
test result is true.
|
StateFuture<Boolean> |
StateFuture.thenConditionallyAccept(FunctionWithException<? super T,Boolean,? extends Exception> condition,
ThrowingConsumer<? super T,? extends Exception> actionIfTrue,
ThrowingConsumer<? super T,? extends Exception> actionIfFalse) |
Apply a condition test on the result of this StateFuture, and try to perform one action out
of two based on the result.
|
<U> StateFuture<Tuple2<Boolean,U>> |
StateFuture.thenConditionallyApply(FunctionWithException<? super T,Boolean,? extends Exception> condition,
FunctionWithException<? super T,? extends U,? extends Exception> actionIfTrue) |
Apply a condition test on the result of this StateFuture, and try to perform the action if
test result is true.
|
<U,V>
StateFuture<Tuple2<Boolean,Object>> |
StateFuture.thenConditionallyApply(FunctionWithException<? super T,Boolean,? extends Exception> condition,
FunctionWithException<? super T,? extends U,? extends Exception> actionIfTrue,
FunctionWithException<? super T,? extends V,? extends Exception> actionIfFalse) |
Apply a condition test on the result of this StateFuture, and try to perform one action out
of two based on the result.
|
<U> StateFuture<Tuple2<Boolean,U>> |
StateFuture.thenConditionallyCompose(FunctionWithException<? super T,Boolean,? extends Exception> condition,
FunctionWithException<? super T,? extends StateFuture<U>,? extends Exception> actionIfTrue) |
Apply a condition test on the result of this StateFuture, and try to perform the action if
test result is true.
|
<U,V>
StateFuture<Tuple2<Boolean,Object>> |
StateFuture.thenConditionallyCompose(FunctionWithException<? super T,Boolean,? extends Exception> condition,
FunctionWithException<? super T,? extends StateFuture<U>,? extends Exception> actionIfTrue,
FunctionWithException<? super T,? extends StateFuture<V>,? extends Exception> actionIfFalse) |
Apply a condition test on the result of this StateFuture, and try to perform one action out
of two based on the result.
|