akka.stream.impl.fusing

Class SubSink<T>

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>

akka.stream.stage.GraphStage<SinkShape<T>>

akka.stream.impl.fusing.SubSink<T>

All Implemented Interfaces:

Graph<SinkShape<T>,NotUsed>

public final class SubSink<T>
extends GraphStage<SinkShape<T>>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SubSink.Cancel$
static class	SubSink.CancelScheduledBeforeMaterialization$ A Cancel command was scheduled before materialization
static interface	SubSink.Command Steady state: sink has been materialized, commands can be delivered through the callback
static class	SubSink.CommandScheduledBeforeMaterialization A command was scheduled before materialization
static class	SubSink.RequestOne$
static class	SubSink.RequestOneScheduledBeforeMaterialization$ A RequestOne command was scheduled before materialization
static interface	SubSink.State
static class	SubSink.Uninitialized$ Not yet materialized and no command has been scheduled

Constructor Summary

Constructors

Constructor and Description
SubSink(java.lang.String name, scala.Function1<ActorSubscriberMessage,scala.runtime.BoxedUnit> externalCallback)

Method Summary

Modifier and Type	Method and Description
static Graph<S,M>	addAttributes(Attributes attr)
static Graph<S,M>	async()
void	cancelSubstream()
GraphStageLogic	createLogic(Attributes attr)
static scala.Tuple2<GraphStageLogic,NotUsed>	createLogicAndMaterializedValue(Attributes inheritedAttributes)
Attributes	initialAttributes()
static StreamLayout.Module	module()
static Graph<S,M>	named(java.lang.String name)
void	pullSubstream()
SinkShape<T>	shape() The shape of a graph is all that is externally visible: its inlets and outlets.
java.lang.String	toString()
static Graph<S,M>	withAttributes(Attributes attr)

Methods inherited from class akka.stream.stage.GraphStage

createLogicAndMaterializedValue

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue

module, 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, named

Constructor Detail

SubSink

public SubSink(java.lang.String name,
               scala.Function1<ActorSubscriberMessage,scala.runtime.BoxedUnit> externalCallback)

Method Detail

named

public static Graph<S,M> named(java.lang.String name)

async

public static Graph<S,M> async()

addAttributes

public static Graph<S,M> addAttributes(Attributes attr)

module

public static final StreamLayout.Module module()

withAttributes

public static final Graph<S,M> withAttributes(Attributes attr)

createLogicAndMaterializedValue

public static final scala.Tuple2<GraphStageLogic,NotUsed> createLogicAndMaterializedValue(Attributes inheritedAttributes)

initialAttributes

public Attributes initialAttributes()

Overrides:

initialAttributes in class GraphStageWithMaterializedValue<SinkShape<T>,NotUsed>

shape

public SinkShape<T> shape()

Description copied from interface: Graph

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

Returns:

(undocumented)

pullSubstream

public void pullSubstream()

cancelSubstream

public void cancelSubstream()

createLogic

public GraphStageLogic createLogic(Attributes attr)

Specified by:

createLogic in class GraphStage<SinkShape<T>>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object