package pf
Type Members
- class DeciderBuilder extends AnyRef
Used for building a partial function for
Actor.supervisorStrategy()
.Used for building a partial function for
Actor.supervisorStrategy()
. * Inside an actor you can use it like this with Java 8 to define your supervisorStrategy.Example:
@Override private static SupervisorStrategy strategy = new OneForOneStrategy(10, Duration.ofMinutes(1), DeciderBuilder. match(ArithmeticException.class, e -> resume()). match(NullPointerException.class, e -> restart()). match(IllegalArgumentException.class, e -> stop()). matchAny(o -> escalate()).build()); @Override public SupervisorStrategy supervisorStrategy() { return strategy; }
- final class FI extends AnyRef
Class that encapsulates Functional Interfaces used for creating partial functions.
Class that encapsulates Functional Interfaces used for creating partial functions.
These classes are kept for compatibility, but for future API's please prefer the ones in
org.apache.pekko.japi.function
. - class FSMStateFunctionBuilder[S, D] extends AnyRef
Builder used to create a partial function for
org.apache.pekko.actor.FSM#whenUnhandled
.Builder used to create a partial function for
org.apache.pekko.actor.FSM#whenUnhandled
.- Annotations
- @SuppressWarnings()
- class FSMStopBuilder[S, D] extends AnyRef
Builder used to create a partial function for
org.apache.pekko.actor.FSM#onTermination
. - class FSMTransitionHandlerBuilder[S] extends AnyRef
Builder used to create a partial function for
org.apache.pekko.actor.FSM#onTransition
. - class Match[I, R] extends AbstractMatch[I, R]
Version of
scala.PartialFunction
that can be built during runtime from Java. - final class PFBuilder[I, R] extends AbstractPFBuilder[I, R]
A builder for
scala.PartialFunction
. - class ReceiveBuilder extends AnyRef
Used for building a partial function for
org.apache.pekko.actor.AbstractActor#createReceive() AbstractActor.createReceive()
.Used for building a partial function for
org.apache.pekko.actor.AbstractActor#createReceive() AbstractActor.createReceive()
.There is both a match on type only, and a match on type and predicate.
Inside an actor you can use it like this:
Example:
@Override public Receive createReceive() { return receiveBuilder() .match(Double.class, d -> { getSender().tell(d.isNaN() ? 0 : d, self()); }) .match(Integer.class, i -> { getSender().tell(i * 10, self()); }) .match(String.class, s -> s.startsWith("foo"), s -> { getSender().tell(s.toUpperCase(), self()); }) .build() ); }
- class UnitMatch[I] extends AbstractMatch[I, BoxedUnit]
Version of
scala.PartialFunction
that can be built during runtime from Java.Version of
scala.PartialFunction
that can be built during runtime from Java. This is a specialized version ofUnitMatch
to map java void methods toscala.runtime.BoxedUnit
. - final class UnitPFBuilder[I] extends AbstractPFBuilder[I, BoxedUnit]
A builder for
scala.PartialFunction
.A builder for
scala.PartialFunction
. This is a specialized version ofPFBuilder
to map java void methods toscala.runtime.BoxedUnit
.