Package org.apache.pekko.persistence.testkit

Class ProcessingPolicy.DefaultPolicies.ReturnAfterNextNCond

java.lang.Object

org.apache.pekko.persistence.testkit.ProcessingPolicy.DefaultPolicies.ReturnAfterNextNCond

All Implemented Interfaces:

ProcessingPolicy<U>

Direct Known Subclasses:

ProcessingPolicy.DefaultPolicies.CountNextNCond

Enclosing interface:

ProcessingPolicy.DefaultPolicies<U>

public static class ProcessingPolicy.DefaultPolicies.ReturnAfterNextNCond
extends Object
implements ProcessingPolicy<U>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.persistence.testkit.ProcessingPolicy

ProcessingPolicy.DefaultPolicies<U>

Constructor Summary

Constructors

Constructor	Description
ReturnAfterNextNCond(scala.Function0<ProcessingResult> returnOnTrigger, scala.Function0<ProcessingResult> returnNonTrigger, scala.Function2<String,U,Object> cond)

Method Summary

Modifier and Type	Method	Description
ProcessingResult	tryProcess(String persistenceId, U processingUnit)	Emulates behavior of the storage.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ReturnAfterNextNCond

public ReturnAfterNextNCond(scala.Function0<ProcessingResult> returnOnTrigger,
 scala.Function0<ProcessingResult> returnNonTrigger,
 scala.Function2<String,U,Object> cond)

Method Details

tryProcess

public ProcessingResult tryProcess(String persistenceId,
 U processingUnit)

Description copied from interface: ProcessingPolicy

Emulates behavior of the storage. The function is invoked when any of the plugin's operations is executed. If you need this operation to succeed return ProcessingSuccess, otherwise you should return some of the ProcessingFailure's.

Specified by:

tryProcess in interface ProcessingPolicy<U>

Parameters:

persistenceId - persistenceId or other id of the processing operation

processingUnit - details about current operation to be executed

Returns:

needed result of processing the operation