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

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

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 Details

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 interface StoreObserver

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 interface StoreObserver

Parameters:

binEntry - the associated entry

exception - 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 interface StoreObserver