Uploaded image for project: 'Infinispan'
  1. Infinispan
  2. ISPN-8310

LockedStream invokeAll

This issue belongs to an archived project. You can view it, but you can't modify it. Learn more

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Done
    • Icon: Major Major
    • 9.2.0.Final
    • None
    • None
    • None

      We need a way to run a command for all data in the cache (while under a lock) but also return a value for the data processed.

      There are a few different APIs we could do for this having a Cache<K, V>

      blocking variant

      <R> Map<K, R> evalAll(BiFunction<Cache<K, V>, ? super CacheEntry<K, V>, R> biFunction)
      

      back pressure aware variant - this would have to be a hot observer on subscribe

      <R> Publisher<R> evalAll(BiFunction<Cache<K, V>, ? super CacheEntry<K, V> R> biFunction)
      

              wburns@redhat.com Will Burns
              wburns@redhat.com Will Burns
              Archiver:
              rhn-support-adongare Amol Dongare

                Created:
                Updated:
                Resolved:
                Archived: