akka.stream.actor

Class ActorSubscriberState

java.lang.Object

akka.stream.actor.ActorSubscriberState

All Implemented Interfaces:

Extension

public class ActorSubscriberState
extends java.lang.Object
implements Extension

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ActorSubscriberState.State
static class	ActorSubscriberState.State$

Constructor Summary

Constructors

Constructor and Description
ActorSubscriberState()

Method Summary

Modifier and Type	Method and Description
static ActorSubscriberState	createExtension(ExtendedActorSystem system)
scala.Option<ActorSubscriberState.State>	get(ActorRef ref)
static ActorSubscriberState$	lookup()
void	remove(ActorRef ref)
void	set(ActorRef ref, ActorSubscriberState.State s)

Methods inherited from class java.lang.Object

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

Constructor Detail

ActorSubscriberState

public ActorSubscriberState()

Method Detail

lookup

public static ActorSubscriberState$ lookup()

createExtension

public static ActorSubscriberState createExtension(ExtendedActorSystem system)

get

public scala.Option<ActorSubscriberState.State> get(ActorRef ref)

set

public void set(ActorRef ref,
                ActorSubscriberState.State s)

remove

public void remove(ActorRef ref)