Package akka.actor.typed.internal

Class EventStreamExtension

java.lang.Object

akka.actor.typed.internal.EventStreamExtension

All Implemented Interfaces:

Extension

public final class EventStreamExtension
extends java.lang.Object
implements Extension

INTERNAL API

Exposes a typed actor that interacts with the akka.actor.ActorSystem.eventStream.

It is used as an extension to ensure a single instance per actor system.

Constructor Summary

Constructors

Constructor	Description
EventStreamExtension(ActorSystem<?> actorSystem)

Method Summary

Modifier and Type	Method	Description
static T	apply(ActorSystem<?> system)
static EventStreamExtension	createExtension(ActorSystem<?> system)
static boolean	equals(java.lang.Object other)
static int	hashCode()
static ExtensionId<T>	id()
ActorRef<EventStream.Command>	ref()

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStreamExtension

public EventStreamExtension(ActorSystem<?> actorSystem)

Method Detail

createExtension

public static EventStreamExtension createExtension(ActorSystem<?> system)

apply

public static final T apply(ActorSystem<?> system)

hashCode

public static final int hashCode()

equals

public static final boolean equals(java.lang.Object other)

id

public static ExtensionId<T> id()

ref

public ActorRef<EventStream.Command> ref()