Modifier and Type | Method and Description |
---|---|
void |
AtomicLongProxy.alter(IFunction<Long,Long> function) |
long |
AtomicLongProxy.alterAndGet(IFunction<Long,Long> function) |
InternalCompletableFuture<Long> |
AtomicLongProxy.alterAndGetAsync(IFunction<Long,Long> function) |
InternalCompletableFuture<Void> |
AtomicLongProxy.alterAsync(IFunction<Long,Long> function) |
<R> R |
AtomicLongProxy.apply(IFunction<Long,R> function) |
<R> InternalCompletableFuture<R> |
AtomicLongProxy.applyAsync(IFunction<Long,R> function) |
long |
AtomicLongProxy.getAndAlter(IFunction<Long,Long> function) |
InternalCompletableFuture<Long> |
AtomicLongProxy.getAndAlterAsync(IFunction<Long,Long> function) |
Modifier and Type | Method and Description |
---|---|
void |
AtomicRefProxy.alter(IFunction<T,T> function) |
T |
AtomicRefProxy.alterAndGet(IFunction<T,T> function) |
InternalCompletableFuture<T> |
AtomicRefProxy.alterAndGetAsync(IFunction<T,T> function) |
InternalCompletableFuture<Void> |
AtomicRefProxy.alterAsync(IFunction<T,T> function) |
<R> R |
AtomicRefProxy.apply(IFunction<T,R> function) |
<R> InternalCompletableFuture<R> |
AtomicRefProxy.applyAsync(IFunction<T,R> function) |
T |
AtomicRefProxy.getAndAlter(IFunction<T,T> function) |
InternalCompletableFuture<T> |
AtomicRefProxy.getAndAlterAsync(IFunction<T,T> function) |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<ReadResultSet<E>> |
ClientRingbufferProxy.readManyAsync(long startSequence,
int minCount,
int maxCount,
IFunction<E,Boolean> filter) |
Modifier and Type | Method and Description |
---|---|
void |
IAtomicReference.alter(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it.
|
void |
IAtomicLong.alter(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it.
|
E |
IAtomicReference.alterAndGet(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it and
gets the result.
|
long |
IAtomicLong.alterAndGet(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it and
gets the result.
|
CompletionStage<E> |
IAtomicReference.alterAndGetAsync(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it and
gets the result.
|
CompletionStage<Long> |
IAtomicLong.alterAndGetAsync(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it and gets
the result.
|
CompletionStage<Void> |
IAtomicReference.alterAsync(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it.
|
CompletionStage<Void> |
IAtomicLong.alterAsync(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it.
|
<R> R |
IAtomicReference.apply(IFunction<E,R> function)
Applies a function on the value, the actual stored value will not
change.
|
<R> R |
IAtomicLong.apply(IFunction<Long,R> function)
Applies a function on the value, the actual stored value will not change.
|
<R> CompletionStage<R> |
IAtomicReference.applyAsync(IFunction<E,R> function)
Applies a function on the value, the actual stored value will not
change.
|
<R> CompletionStage<R> |
IAtomicLong.applyAsync(IFunction<Long,R> function)
Applies a function on the value, the actual stored value will not
change.
|
E |
IAtomicReference.getAndAlter(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it on
and gets the old value.
|
long |
IAtomicLong.getAndAlter(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it on and
gets the old value.
|
CompletionStage<E> |
IAtomicReference.getAndAlterAsync(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it on
and gets the old value.
|
CompletionStage<Long> |
IAtomicLong.getAndAlterAsync(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it on and
gets the old value.
|
Constructor and Description |
---|
AlterOp(String name,
IFunction<Long,Long> function,
AlterOp.AlterResultType alterResultType) |
ApplyOp(String name,
IFunction<Long,R> function) |
Modifier and Type | Method and Description |
---|---|
void |
AtomicLongProxy.alter(IFunction<Long,Long> function) |
long |
AtomicLongProxy.alterAndGet(IFunction<Long,Long> function) |
InternalCompletableFuture<Long> |
AtomicLongProxy.alterAndGetAsync(IFunction<Long,Long> function) |
InternalCompletableFuture<Void> |
AtomicLongProxy.alterAsync(IFunction<Long,Long> function) |
<R> R |
AtomicLongProxy.apply(IFunction<Long,R> function) |
<R> InternalCompletableFuture<R> |
AtomicLongProxy.applyAsync(IFunction<Long,R> function) |
long |
AtomicLongProxy.getAndAlter(IFunction<Long,Long> function) |
InternalCompletableFuture<Long> |
AtomicLongProxy.getAndAlterAsync(IFunction<Long,Long> function) |
Modifier and Type | Method and Description |
---|---|
void |
AtomicRefProxy.alter(IFunction<T,T> function) |
T |
AtomicRefProxy.alterAndGet(IFunction<T,T> function) |
InternalCompletableFuture<T> |
AtomicRefProxy.alterAndGetAsync(IFunction<T,T> function) |
InternalCompletableFuture<Void> |
AtomicRefProxy.alterAsync(IFunction<T,T> function) |
<R> R |
AtomicRefProxy.apply(IFunction<T,R> function) |
<R> InternalCompletableFuture<R> |
AtomicRefProxy.applyAsync(IFunction<T,R> function) |
T |
AtomicRefProxy.getAndAlter(IFunction<T,T> function) |
InternalCompletableFuture<T> |
AtomicRefProxy.getAndAlterAsync(IFunction<T,T> function) |
Modifier and Type | Method and Description |
---|---|
void |
LongRegisterProxy.alter(IFunction<Long,Long> function) |
long |
LongRegisterProxy.alterAndGet(IFunction<Long,Long> function) |
InternalCompletableFuture<Long> |
LongRegisterProxy.alterAndGetAsync(IFunction<Long,Long> function) |
InternalCompletableFuture<Void> |
LongRegisterProxy.alterAsync(IFunction<Long,Long> function) |
<R> R |
LongRegisterProxy.apply(IFunction<Long,R> function) |
<R> InternalCompletableFuture<R> |
LongRegisterProxy.applyAsync(IFunction<Long,R> function) |
long |
LongRegisterProxy.getAndAlter(IFunction<Long,Long> function) |
InternalCompletableFuture<Long> |
LongRegisterProxy.getAndAlterAsync(IFunction<Long,Long> function) |
Modifier and Type | Method and Description |
---|---|
void |
ClientLongRegisterProxy.alter(IFunction<Long,Long> function) |
long |
ClientLongRegisterProxy.alterAndGet(IFunction<Long,Long> function) |
InternalCompletableFuture<Long> |
ClientLongRegisterProxy.alterAndGetAsync(IFunction<Long,Long> function) |
InternalCompletableFuture<Void> |
ClientLongRegisterProxy.alterAsync(IFunction<Long,Long> function) |
<R> R |
ClientLongRegisterProxy.apply(IFunction<Long,R> function) |
<R> InternalCompletableFuture<R> |
ClientLongRegisterProxy.applyAsync(IFunction<Long,R> function) |
long |
ClientLongRegisterProxy.getAndAlter(IFunction<Long,Long> function) |
InternalCompletableFuture<Long> |
ClientLongRegisterProxy.getAndAlterAsync(IFunction<Long,Long> function) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<ReadResultSet<E>> |
Ringbuffer.readManyAsync(long startSequence,
int minCount,
int maxCount,
IFunction<E,Boolean> filter)
Reads a batch of items from the Ringbuffer.
|
Modifier and Type | Method and Description |
---|---|
CompletionStage<ReadResultSet<E>> |
RingbufferProxy.readManyAsync(long startSequence,
int minCount,
int maxCount,
IFunction<E,Boolean> filter) |
Constructor and Description |
---|
ReadResultSetImpl(int minSize,
int maxSize,
SerializationService serializationService,
IFunction<O,Boolean> filter) |
Constructor and Description |
---|
ReadManyOperation(String name,
long startSequence,
int minSize,
int maxSize,
IFunction<O,Boolean> filter) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.