[
https://issues.jboss.org/browse/ISPN-8310?page=com.atlassian.jira.plugin....
]
William Burns updated ISPN-8310:
--------------------------------
Description:
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
{code}
<R> Map<K, R> evalAll(BiFunction<Cache<K, V>, ? super
CacheEntry<K, V>, R> biFunction)
{code}
back pressure aware variant - this would have to be a hot observer on subscribe
{code}
<R> Publisher<R> evalAll(BiFunction<Cache<K, V>, ? super
CacheEntry<K, V> R> biFunction)
{code}
was:
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
{code}
<R> Map<K, R> evalAll(BiFunction<Cache<K, V>, ? super
CacheEntry<K, V>, R> biFunction)
{code}
back pressure aware variant - this would have to be a hot observer on subscribe
{code}
<R> Producer<R> evalAll(BiFunction<Cache<K, V>, ? super
CacheEntry<K, V> R> biFunction)
{code}
LockedStream invokeAll
----------------------
Key: ISPN-8310
URL:
https://issues.jboss.org/browse/ISPN-8310
Project: Infinispan
Issue Type: Feature Request
Reporter: William Burns
Assignee: William Burns
Fix For: 9.2.0.Alpha1
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
{code}
<R> Map<K, R> evalAll(BiFunction<Cache<K, V>, ? super
CacheEntry<K, V>, R> biFunction)
{code}
back pressure aware variant - this would have to be a hot observer on subscribe
{code}
<R> Publisher<R> evalAll(BiFunction<Cache<K, V>, ? super
CacheEntry<K, V> R> biFunction)
{code}
--
This message was sent by Atlassian JIRA
(v7.2.3#72005)