Package com.tangosol.net.cache
Class ReadWriteBackingMap.NonBlockingEntryStoreWrapper.StoreOperationObserver
- java.lang.Object
-
- com.tangosol.net.cache.ReadWriteBackingMap.NonBlockingEntryStoreWrapper.StoreOperationObserver
-
- All Implemented Interfaces:
StoreObserver
- Enclosing class:
- ReadWriteBackingMap.NonBlockingEntryStoreWrapper
public class ReadWriteBackingMap.NonBlockingEntryStoreWrapper.StoreOperationObserver extends Object implements StoreObserver
Callbacks invoked by NonBlockingEntryStore implementer to handle the result of store operations.
-
-
Constructor Summary
Constructors Constructor Description StoreOperationObserver()
Default constructor.StoreOperationObserver(Set setEntries)
Constructor with initial set of entries to be stored.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
Complete the current operation.void
onError(BinaryEntry binEntry, Exception exception)
Indicate that the corresponding entry is in error, due to the given exception.void
onNext(BinaryEntry binEntry)
Indicates the associated operation (load or store) has completed successfully and applied to the provided BinaryEntry.
-
-
-
Constructor Detail
-
StoreOperationObserver
public StoreOperationObserver()
Default constructor.
-
StoreOperationObserver
public StoreOperationObserver(Set setEntries)
Constructor with initial set of entries to be stored.- Parameters:
setEntries
- the entries that need storing
-
-
Method Detail
-
onNext
public void onNext(BinaryEntry binEntry)
Indicates the associated operation (load or store) has completed successfully and applied to the provided BinaryEntry.- Specified by:
onNext
in interfaceStoreObserver
- Parameters:
binEntry
- the associated entry
-
onError
public void onError(BinaryEntry binEntry, Exception exception)
Indicate that the corresponding entry is in error, due to the given exception.- Specified by:
onError
in interfaceStoreObserver
- Parameters:
binEntry
- the associated entryexception
- exception providing error details
-
onComplete
public void onComplete()
Complete the current operation. This is the last call to make on an observer, to signify that no further processing is necessary.- Specified by:
onComplete
in interfaceStoreObserver
-
-