Package com.tangosol.net.cache

Class ReadWriteBackingMap.NonBlockingEntryStoreWrapper.LoadOperationObserver

java.lang.Object
com.tangosol.net.cache.ReadWriteBackingMap.NonBlockingEntryStoreWrapper.LoadOperationObserver
All Implemented Interfaces:
StoreObserver
Enclosing class:
ReadWriteBackingMap.NonBlockingEntryStoreWrapper
public class ReadWriteBackingMap.NonBlockingEntryStoreWrapper.LoadOperationObserver extends Object implements StoreObserver
Callbacks invoked by NonBlockingEntryStore implementation to handle the result of load operations.

  • Constructor Details

    • LoadOperationObserver

      public LoadOperationObserver()
      Default constructor

    • LoadOperationObserver

      public LoadOperationObserver(int cEntries)
      Constructor for loadAll() code path.
      Parameters:
      cEntries - countdown gate for synchronization

  • 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

    • waitForCompleted

      protected void waitForCompleted()
      Synchronize loadInternal or loadAllInternal with responses.
      Throws:
      RuntimeException - upon interruption

    • getProcessedEntries

      protected Set getProcessedEntries()
      Set of entries successfully processed in loadAll().
      Returns:
      set of good entries