portals-core
API
Generated with
portals-core/portals/portals.runtime/portals.runtime.parallel/ParallelRuntimePartition

ParallelRuntimePartition

portals.runtime.parallel.ParallelRuntimePartition
See theParallelRuntimePartition companion object
class ParallelRuntimePartition(partition: Int, nPartitions: Int, ctx: ActorContext[Message]) extends AbstractBehavior[Message]

Attributes

Companion
object
Graph
Supertypes
class AbstractBehavior[Message]
class ExtensibleBehavior[Message]
class Behavior[Message]
class Object
trait Matchable
class Any
Show all

Members list

Value members

Concrete methods

def feed(batch: EventBatch): Unit
def launch(app: Application): Unit
override def onMessage(msg: Message): Behavior[Message]

Implement this method to process an incoming message and return the next behavior.

Implement this method to process an incoming message and return the next behavior.

The returned behavior can in addition to normal behaviors be one of the canned special objects:

  • returning stopped will terminate this Behavior

  • returning this or same designates to reuse the current Behavior

  • returning unhandled keeps the same Behavior and signals that the message was not yet handled

Attributes

Definition Classes
AbstractBehavior
def resume(path: Path, task: Path, list: List[WrappedEvent[_]]): Unit
def step(): Unit

Inherited methods

final def narrow[U <: Message]: Behavior[U]

Narrow the type of this Behavior, which is always a safe operation. This method is necessary to implement the contravariant nature of Behavior (which cannot be expressed directly due to type inference problems).

Narrow the type of this Behavior, which is always a safe operation. This method is necessary to implement the contravariant nature of Behavior (which cannot be expressed directly due to type inference problems).

Attributes

Inherited from:
Behavior
def onSignal: PartialFunction[Signal, Behavior[T]]

Override this method to process an incoming pekko.actor.typed.Signal and return the next behavior. This means that all lifecycle hooks, ReceiveTimeout, Terminated and Failed messages can initiate a behavior change.

Override this method to process an incoming pekko.actor.typed.Signal and return the next behavior. This means that all lifecycle hooks, ReceiveTimeout, Terminated and Failed messages can initiate a behavior change.

The returned behavior can in addition to normal behaviors be one of the canned special objects:

  • returning stopped will terminate this Behavior
  • returning this or same designates to reuse the current Behavior
  • returning unhandled keeps the same Behavior and signals that the message was not yet handled

By default, partial function is empty and does not handle any signals.

Attributes

Inherited from:
AbstractBehavior
final override def receive(ctx: TypedActorContext[Message], msg: Message): Behavior[T]

Process an incoming message and return the next behavior.

Process an incoming message and return the next behavior.

The returned behavior can in addition to normal behaviors be one of the canned special objects:

  • returning stopped will terminate this Behavior
  • returning same designates to reuse the current Behavior
  • returning unhandled keeps the same Behavior and signals that the message was not yet handled

Code calling this method should use Behavior$ canonicalize to replace the special objects with real Behaviors.

Attributes

Definition Classes
AbstractBehavior -> ExtensibleBehavior
Inherited from:
AbstractBehavior
final override def receiveSignal(ctx: TypedActorContext[Message], msg: Signal): Behavior[T]

Process an incoming Signal and return the next behavior. This means that all lifecycle hooks, ReceiveTimeout, Terminated and Failed messages can initiate a behavior change.

Process an incoming Signal and return the next behavior. This means that all lifecycle hooks, ReceiveTimeout, Terminated and Failed messages can initiate a behavior change.

The returned behavior can in addition to normal behaviors be one of the canned special objects:

  • returning stopped will terminate this Behavior
  • returning same designates to reuse the current Behavior
  • returning unhandled keeps the same Behavior and signals that the message was not yet handled

Code calling this method should use Behavior$ canonicalize to replace the special objects with real Behaviors.

Attributes

Definition Classes
AbstractBehavior -> ExtensibleBehavior
Inherited from:
AbstractBehavior

Inherited fields

protected val context: ActorContext[Message]

Attributes

Inherited from:
AbstractBehavior
Generated with