Package org.apache.pekko.actor.typed.internal

Class BehaviorImpl$

java.lang.Object

org.apache.pekko.actor.typed.internal.BehaviorImpl$

public class BehaviorImpl$
extends Object

INTERNAL API

Field Summary

Fields

Modifier and Type	Field	Description
static final BehaviorImpl$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
BehaviorImpl$()

Method Summary

Modifier and Type	Method	Description
<T> BehaviorImpl.ContextAs<T>	ContextAs(TypedActorContext<T> ctx)
<T> Behavior<T>	empty()
<T> Behavior<T>	failed(Throwable cause)
<T> Behavior<T>	ignore()
<O, I> Behavior<O>	intercept(scala.Function0<BehaviorInterceptor<O,I>> interceptor, Behavior<I> behavior)	Intercept messages and signals for a behavior by first passing them to a pekko.actor.typed.BehaviorInterceptor
<T> Behavior<T>	same()
<T> Behavior<T>	stopped()
<T> Behavior<T>	stopped(scala.Function0<scala.runtime.BoxedUnit> postStop)
org.apache.pekko.actor.typed.internal.BehaviorImpl.StoppedBehavior<scala.runtime.Nothing$>	StoppedBehavior()
<O, I> Behavior<O>	transformMessages(Behavior<I> behavior, scala.PartialFunction<O,I> matcher, scala.reflect.ClassTag<O> evidence$1)
<T> Behavior<T>	unhandled()
scala.PartialFunction<scala.Tuple2<TypedActorContext<scala.runtime.Nothing$>,Signal>,Behavior<scala.runtime.Nothing$>>	unhandledSignal()

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final BehaviorImpl$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

BehaviorImpl$

public BehaviorImpl$()

Method Details

ContextAs

public <T> BehaviorImpl.ContextAs<T> ContextAs(TypedActorContext<T> ctx)

transformMessages

public <O,
I> Behavior<O> transformMessages(Behavior<I> behavior,
 scala.PartialFunction<O,I> matcher,
 scala.reflect.ClassTag<O> evidence$1)

same

public <T> Behavior<T> same()

unhandled

public <T> Behavior<T> unhandled()

stopped

public <T> Behavior<T> stopped()

stopped

public <T> Behavior<T> stopped(scala.Function0<scala.runtime.BoxedUnit> postStop)

empty

public <T> Behavior<T> empty()

ignore

public <T> Behavior<T> ignore()

failed

public <T> Behavior<T> failed(Throwable cause)

unhandledSignal

public scala.PartialFunction<scala.Tuple2<TypedActorContext<scala.runtime.Nothing$>,Signal>,Behavior<scala.runtime.Nothing$>> unhandledSignal()

StoppedBehavior

public org.apache.pekko.actor.typed.internal.BehaviorImpl.StoppedBehavior<scala.runtime.Nothing$> StoppedBehavior()

intercept

public <O,
I> Behavior<O> intercept(scala.Function0<BehaviorInterceptor<O,I>> interceptor,
 Behavior<I> behavior)

Intercept messages and signals for a behavior by first passing them to a pekko.actor.typed.BehaviorInterceptor

When a behavior returns a new behavior as a result of processing a signal or message and that behavior already contains the same interceptor (defined by the isSame method on the BehaviorInterceptor) only the innermost interceptor is kept. This is to protect against stack overflow when recursively defining behaviors.