tap(...) call again.
- *
- * @param signal
- * procedure to invoke with the {@link ActorContext} and the
- * {@link akka.typed.Signal} as arguments before delivering the signal to
- * the wrapped behavior
- * @param message
- * procedure to invoke with the {@link ActorContext} and the received
- * message as arguments before delivering the signal to the wrapped
- * behavior
- * @param behavior
- * initial behavior to be wrapped
- * @return the decorated behavior
- */
- static public monitor(...) call again.
- *
- * @param monitor
- * ActorRef to which to copy all received messages
- * @param behavior
- * initial behavior to be wrapped
- * @return the decorated behavior
- */
- static public Thr will not be
- * caught and thus lead to the termination of the actor.
- *
- * It is possible to specify different supervisor strategies, such as restart,
- * resume, backoff.
- *
- * @param clazz
- * the type of exceptions that shall be caught
- * @param strategy
- * whether to restart, resume, or backoff the actor upon a caught failure
- * @param initialBehavior
- * the initial behavior, that is also restored during a restart
- * @return the wrapped behavior
- */
- static public
- * Behavior<String> s = immutable((ctx, msg) -> {
- * System.out.println(msg);
- * return same();
- * });
- * Behavior<Number> n = widened(s, pf -> pf.
- * match(BigInteger.class, i -> "BigInteger(" + i + ")").
- * match(BigDecimal.class, d -> "BigDecimal(" + d + ")")
- * // drop all other kinds of Number
- * );
- * MutableBehavior that typically holds mutable state as
- * instance variables in the concrete MutableBehavior implementation class.
- *
- * Creation of the behavior instance is deferred, i.e. it is created via the producer
- * function. The reason for the deferred creation is to avoid sharing the same instance in
- * multiple actors, and to create a new instance when the actor is restarted.
- *
- * @param producer
- * behavior factory that takes the child actor’s context as argument
- * @return the deferred behavior
- */
- static public ActorContext in addition provides access to the Actor’s own identity
- * ({@link #getSelf “self”}), the {@link akka.typed.ActorSystem} it is part of, methods for querying the list
- * of child Actors it created, access to {@link akka.typed.Terminated DeathWatch} and timed
- * message scheduling.
- */
-public interface ActorContextscala.concurrent.duration.Duration.Undefined to switch off this mechanism.
- */
- public void setReceiveTimeout(FiniteDuration d, T msg);
-
- /**
- * Cancel the sending of receive timeout notifications.
- */
- public void cancelReceiveTimeout();
-
- /**
- * Schedule the sending of the given message to the given target Actor after
- * the given time period has elapsed. The scheduled action can be cancelled by
- * invoking {@link akka.actor.Cancellable#cancel} on the returned handle.
- */
- public Cancellable schedule(FiniteDuration delay, ActorRef target, U msg);
-
- /**
- * This Actor’s execution context. It can be used to run asynchronous tasks
- * like scala.concurrent.Future combinators.
- */
- public ExecutionContextExecutor getExecutionContext();
-
- /**
- * Create a child actor that will wrap messages such that other Actor’s
- * protocols can be ingested by this Actor. You are strongly advised to cache
- * these ActorRefs or to stop them when no longer needed.
- *
- * The name of the child actor will be composed of a unique identifier
- * starting with a dollar sign to which the given name argument is appended,
- * with an inserted hyphen between these two parts. Therefore the given name
- * argument does not need to be unique within the scope of the parent actor.
- */
- public ActorRef createAdapter(Function