Class CallingThreadDispatcher

INTERNAL API

Used to run an actor on the foreground thread.

Inheritance
object
MessageDispatcher
CallingThreadDispatcher
Inherited Members
Namespace: Akka.TestKit
Assembly: Akka.TestKit.dll
Syntax
public class CallingThreadDispatcher : MessageDispatcher

Constructors

| Edit this page View Source

CallingThreadDispatcher(MessageDispatcherConfigurator)

Declaration
public CallingThreadDispatcher(MessageDispatcherConfigurator configurator)
Parameters
Type Name Description
MessageDispatcherConfigurator configurator

Fields

| Edit this page View Source

Id

HOCON id of the CallingThreadDispatcher

Declaration
public static string Id
Field Value
Type Description
string

Methods

| Edit this page View Source

ExecuteTask(IRunnable)

Schedules the IRunnable to be executed.

Declaration
protected override void ExecuteTask(IRunnable run)
Parameters
Type Name Description
IRunnable run

The asynchronous task we're going to run
Overrides
| Edit this page View Source

Shutdown()

INTERNAL API

Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached

Declaration
protected override void Shutdown()
Overrides
Akka.Dispatch.MessageDispatcher.Shutdown()
Remarks

MUST BE IDEMPOTENT

Extension Methods