Skip to content

Commit

Permalink
Add back public methods removed from AsynchronousAgent and InvocableM…
Browse files Browse the repository at this point in the history
…apHelper

(merge main -> ce/main 104782)

[git-p4: depot-paths = "//dev/coherence-ce/main/": change = 104786]
  • Loading branch information
thegridman committed Nov 21, 2023
1 parent f65ac7e commit 36e4f3b
Show file tree
Hide file tree
Showing 4 changed files with 55 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,18 @@
public abstract class AsynchronousAgent<T>
implements FlowControl, Future<T>
{
/**
* Construct the agent.
*
* @param iOrderId a unit-of-order id associated with this agent. Ordering
* semantics of operations based on this id are defined
* by subclasses
*/
protected AsynchronousAgent(int iOrderId)
{
this(iOrderId, null);
}

/**
* Construct the agent.
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,27 @@
public abstract class InvocableMapHelper
extends Base
{
/**
* Invoke the specified EntryProcessor asynchronously.
*
* @param cache the cache to invoke against
* @param key the key to invoke upon
* @param proc the processor to invoke
*
* @param <K> the key type
* @param <V> the value type
* @param <R> the result type
*
* @return a CompletableFuture which will contain the result
*
* @deprecated As of Coherence 14.1.1, use enhanced
* {@link #invokeAsync(NamedCache, Object, int, InvocableMap.EntryProcessor, BiConsumer[])}.
*/
public static <K, V, R> CompletableFuture<R> invokeAsync(NamedCache<K, V> cache, K key, InvocableMap.EntryProcessor<K, V, R> proc)
{
return invokeAsync(cache, key, Thread.currentThread().hashCode(), proc);
}

/**
* Invoke the specified EntryProcessor asynchronously.
* <p>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,17 @@ public abstract class AbstractAsynchronousAggregator<K, V, P, R>
implements EntryAggregator<K, V, R>
{

/**
* Construct an AsynchronousAggregator for a given streaming aggregator.
*
* @param aggregator the underlying streaming aggregator
* @param iUnitOrderId the unit-of-order id for this aggregator
*/
protected AbstractAsynchronousAggregator(StreamingAggregator<K,V,P,R> aggregator, int iUnitOrderId)
{
this(aggregator, iUnitOrderId, null);
}

/**
* Construct an AsynchronousAggregator for a given streaming aggregator.
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,17 @@ public abstract class AbstractAsynchronousProcessor<K, V, R, T>
{
// ---- constructors ----------------------------------------------------

/**
* Construct AbstractAsynchronousProcessor instance.
*
* @param processor the underlying {@link InvocableMap.EntryProcessor}
* @param iUnitOrderId the unit-of-order id for this processor
*/
protected AbstractAsynchronousProcessor(InvocableMap.EntryProcessor<K, V, R> processor, int iUnitOrderId)
{
this(processor, iUnitOrderId, null);
}

/**
* Construct AbstractAsynchronousProcessor instance.
*
Expand Down

0 comments on commit 36e4f3b

Please sign in to comment.