Package akka.stream.actor

Class ActorPublisherState

java.lang.Object

akka.stream.actor.ActorPublisherState

All Implemented Interfaces:

Extension

public class ActorPublisherState
extends java.lang.Object
implements Extension

INTERNAL API

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor	Description
ActorPublisherState()

Method Summary

Modifier and Type	Method	Description
static T	apply(ActorSystem system)
static T	apply(ClassicActorSystemProvider system)
static ActorPublisherState	createExtension(ExtendedActorSystem system)
static boolean	equals(java.lang.Object other)
scala.Option<ActorPublisherState.State>	get(ActorRef ref)
static int	hashCode()
static ActorPublisherState$	lookup()
void	remove(ActorRef ref)
void	set(ActorRef ref, ActorPublisherState.State s)

Methods inherited from class java.lang.Object

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

Constructor Detail

ActorPublisherState

public ActorPublisherState()

Method Detail

lookup

public static ActorPublisherState$ lookup()

createExtension

public static ActorPublisherState createExtension(ExtendedActorSystem system)

apply

public static T apply(ActorSystem system)

apply

public static T apply(ClassicActorSystemProvider system)

hashCode

public static final int hashCode()

equals

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

get

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

set

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

remove

public void remove(ActorRef ref)