StoreObserver (Oracle® Coherence Java API Reference)

All Known Implementing Classes:

ReadWriteBackingMap.NonBlockingEntryStoreWrapper.LoadOperationObserver, ReadWriteBackingMap.NonBlockingEntryStoreWrapper.StoreOperationObserver
```
public interface StoreObserver<K,V>
```
StoreObserver implementations provide a means for receivers, such as NonBlockingEntryStore, to notify the provider of successful completion (onNext(com.tangosol.util.BinaryEntry<K, V>)) or unsuccessful completion (onError(com.tangosol.util.BinaryEntry<K, V>, java.lang.Exception)).
A call to onComplete() indicates that the receiver will no longer call onNext(com.tangosol.util.BinaryEntry<K, V>) or onError(com.tangosol.util.BinaryEntry<K, V>, java.lang.Exception) on this instance. Note: onComplete() is inferred if onNext or onError is called on all entries received, however it provides a means for receivers to suggest termination of the operation and thus to notify any waiting resources or completion routines of the operation's completion.

Since:

21.06

Author:

mg/hr/as

See Also:

NonBlockingEntryStore

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`onComplete()`	Complete the current operation.
`void`	`onError(BinaryEntry<K,V> binEntry, Exception exception)`	Indicate that the corresponding entry is in error, due to the given exception.
`void`	`onNext(BinaryEntry<K,V> binEntry)`	Indicates the associated operation (load or store) has completed successfully and applied to the provided BinaryEntry.

- Method Detail
  - onNext
```
void onNext(BinaryEntry<K,V> binEntry)
```
    Indicates the associated operation (load or store) has completed successfully and applied to the provided BinaryEntry.
    
    Parameters:
    
    binEntry - the associated entry
    
    Throws:
    
    IllegalStateException - if called after the observer is closed or onComplete() has been called.
  - onError
```
void onError(BinaryEntry<K,V> binEntry,
             Exception exception)
```
    Indicate that the corresponding entry is in error, due to the given exception.
    
    Parameters:
    
    binEntry - the associated entry
    
    exception - exception providing error details
    
    Throws:
    
    IllegalStateException - if called after the observer is closed or onComplete() has been called.
  - onComplete
```
void onComplete()
```
    Complete the current operation. This is the last call to make on an observer, to signify that no further processing is necessary.