Package akka.stream.impl.streamref

Class SourceRefStageImpl<Out>

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<SourceShape<Out>,SinkRef<Out>>

akka.stream.impl.streamref.SourceRefStageImpl<Out>

All Implemented Interfaces:

Graph<SourceShape<Out>,SinkRef<Out>>

public final class SourceRefStageImpl<Out>
extends GraphStageWithMaterializedValue<SourceShape<Out>,SinkRef<Out>>

INTERNAL API: Actual operator implementation backing SourceRefs.

If initialPartnerRef is set, then the remote side is already set up. If it is none, then we are the side creating the ref.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SourceRefStageImpl.ActorRefStage
static interface	SourceRefStageImpl.State
static class	SourceRefStageImpl.WatermarkRequestStrategy
static class	SourceRefStageImpl.WatermarkRequestStrategy$
static interface	SourceRefStageImpl.WeKnowPartner

Nested classes/interfaces inherited from interface akka.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
SourceRefStageImpl(OptionVal<ActorRef> initialPartnerRef)

Method Summary

Modifier and Type	Method	Description
static java.lang.String	CancellationDeadlineTimerKey()
scala.Tuple2<GraphStageLogic,SinkRef<Out>>	createLogicAndMaterializedValue(Attributes inheritedAttributes)
scala.Tuple2<GraphStageLogic,SinkRef<Out>>	createLogicAndMaterializedValue(Attributes inheritedAttributes, Materializer eagerMaterializer)	Grants access to the materializer before preStart of the graph stage logic is invoked.
static java.lang.String	DemandRedeliveryTimerKey()
OptionVal<ActorRef>	initialPartnerRef()
Outlet<Out>	out()
SourceShape<Out>	shape()	The shape of a graph is all that is externally visible: its inlets and outlets.
static java.lang.String	SubscriptionTimeoutTimerKey()
static java.lang.String	TerminationDeadlineTimerKey()
java.lang.String	toString()

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue

initialAttributes, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.Graph

addAttributes, async, async, async, named

Constructor Detail

SourceRefStageImpl

public SourceRefStageImpl(OptionVal<ActorRef> initialPartnerRef)

Method Detail

SubscriptionTimeoutTimerKey

public static java.lang.String SubscriptionTimeoutTimerKey()

DemandRedeliveryTimerKey

public static java.lang.String DemandRedeliveryTimerKey()

TerminationDeadlineTimerKey

public static java.lang.String TerminationDeadlineTimerKey()

CancellationDeadlineTimerKey

public static java.lang.String CancellationDeadlineTimerKey()

initialPartnerRef

public OptionVal<ActorRef> initialPartnerRef()

out

public Outlet<Out> out()

shape

public SourceShape<Out> shape()

Description copied from interface: Graph

The shape of a graph is all that is externally visible: its inlets and outlets.

createLogicAndMaterializedValue

public scala.Tuple2<GraphStageLogic,SinkRef<Out>> createLogicAndMaterializedValue(Attributes inheritedAttributes)

Specified by:

createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<SourceShape<Out>,SinkRef<Out>>

createLogicAndMaterializedValue

public scala.Tuple2<GraphStageLogic,SinkRef<Out>> createLogicAndMaterializedValue(Attributes inheritedAttributes,
                                                                                        Materializer eagerMaterializer)

Description copied from class: GraphStageWithMaterializedValue

Grants access to the materializer before preStart of the graph stage logic is invoked.

INTERNAL API

Overrides:

createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<SourceShape<Out>,SinkRef<Out>>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object