Package org.apache.pekko.persistence.testkit

Class ProcessingPolicy.DefaultPolicies.CountNextNCond

java.lang.Object

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

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

All Implemented Interfaces:

ProcessingPolicy<U>

Direct Known Subclasses:

ProcessingPolicy.DefaultPolicies.FailNextN, ProcessingPolicy.DefaultPolicies.FailNextNCond, ProcessingPolicy.DefaultPolicies.RejectNextN, ProcessingPolicy.DefaultPolicies.RejectNextNCond

Enclosing interface:

ProcessingPolicy.DefaultPolicies<U>

public static class ProcessingPolicy.DefaultPolicies.CountNextNCond
extends ProcessingPolicy.DefaultPolicies.ReturnAfterNextNCond

Nested Class Summary

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

ProcessingPolicy.DefaultPolicies<U>

Constructor Summary

Constructors

Constructor	Description
CountNextNCond(int numberToCount, scala.Function0<ProcessingResult> returnOnTrigger, scala.Function0<ProcessingResult> returnNonTrigger, scala.Function2<String,U,Object> cond, scala.Function0<scala.runtime.BoxedUnit> onLimitExceed)

Method Summary

Methods inherited from class org.apache.pekko.persistence.testkit.ProcessingPolicy.DefaultPolicies.ReturnAfterNextNCond

tryProcess

Methods inherited from class java.lang.Object

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

Constructor Details

CountNextNCond

public CountNextNCond(int numberToCount,
 scala.Function0<ProcessingResult> returnOnTrigger,
 scala.Function0<ProcessingResult> returnNonTrigger,
 scala.Function2<String,U,Object> cond,
 scala.Function0<scala.runtime.BoxedUnit> onLimitExceed)