Package | Description |
---|---|
org.cometd.oort |
Modifier and Type | Class and Description |
---|---|
static class |
OortObject.Result.Deferred<D>
Implementation of
OortObject.Result that allows applications to block,
waiting for the result, via OortObject.Result.Deferred.get(long, TimeUnit) . |
Modifier and Type | Method and Description |
---|---|
void |
OortList.addAndShare(OortObject.Result<Boolean> callback,
E... elements)
Adds the given
elements to the local entity list,
and then broadcasts the addition to all nodes in the cluster. |
void |
OortMap.putAndShare(K key,
V value,
OortObject.Result<V> callback)
Updates a single entry of the local entity map with the given
key and value ,
and broadcasts the operation to all nodes in the cluster. |
void |
OortMap.putIfAbsentAndShare(K key,
V value,
OortObject.Result<V> callback)
Updates a single entry of the local entity map with the given
key and value
if it does not exist yet, and broadcasts the operation to all nodes in the cluster. |
void |
OortMap.removeAndShare(K key,
OortObject.Result<V> callback)
Removes the given
key from the local entity map,
and broadcasts the operation to all nodes in the cluster. |
void |
OortList.removeAndShare(OortObject.Result<Boolean> callback,
E... elements)
Removes the given
elements to the local entity list,
and then broadcasts the removal to all nodes in the cluster. |
void |
OortObject.setAndShare(T newObject,
OortObject.Result<T> callback)
Sets the given new object on this oort object, and then broadcast the new object to all nodes in the cluster.
|
Constructor and Description |
---|
Data(int initialCapacity,
OortObject.Result<T> callback) |
Copyright © 2008–2024 The CometD Project. All rights reserved.