Packages

package pf

Type Members

  1. 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;
    }
    

  2. 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()
  3. class FSMStopBuilder[S, D] extends AnyRef

    Builder used to create a partial function for org.apache.pekko.actor.FSM#onTermination.

  4. class FSMTransitionHandlerBuilder[S] extends AnyRef

    Builder used to create a partial function for org.apache.pekko.actor.FSM#onTransition.

  5. class Match[I, R] extends AbstractMatch[I, R]

    Version of scala.PartialFunction that can be built during runtime from Java.

  6. final class PFBuilder[I, R] extends AbstractPFBuilder[I, R]

    A builder for scala.PartialFunction.

  7. 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()
      );
    }
    

  8. 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 of UnitMatch to map java void methods to scala.runtime.BoxedUnit.

  9. final class UnitPFBuilder[I] extends AbstractPFBuilder[I, BoxedUnit]

    A builder for scala.PartialFunction.

    A builder for scala.PartialFunction. This is a specialized version of PFBuilder to map java void methods to scala.runtime.BoxedUnit.

Ungrouped