public class OutgoingConnectionStage extends GraphStageWithMaterializedValue<FlowShape<ByteString,ByteString>,scala.concurrent.Future<Tcp.OutgoingConnection>>
Constructor and Description |
---|
OutgoingConnectionStage(ActorRef manager,
java.net.InetSocketAddress remoteAddress,
scala.Option<java.net.InetSocketAddress> localAddress,
scala.collection.immutable.Traversable<Inet.SocketOption> options,
boolean halfClose,
scala.concurrent.duration.Duration connectTimeout) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static Graph<S,M> |
async() |
Inlet<ByteString> |
bytesIn() |
Outlet<ByteString> |
bytesOut() |
scala.Tuple2<GraphStageLogic,scala.concurrent.Future<Tcp.OutgoingConnection>> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
FlowShape<ByteString,ByteString> |
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) |
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public OutgoingConnectionStage(ActorRef manager, java.net.InetSocketAddress remoteAddress, scala.Option<java.net.InetSocketAddress> localAddress, scala.collection.immutable.Traversable<Inet.SocketOption> options, boolean halfClose, scala.concurrent.duration.Duration connectTimeout)
public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
public static final StreamLayout.Module module()
public static final Graph<S,M> withAttributes(Attributes attr)
public Inlet<ByteString> bytesIn()
public Outlet<ByteString> bytesOut()
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<FlowShape<ByteString,ByteString>,scala.concurrent.Future<Tcp.OutgoingConnection>>
public FlowShape<ByteString,ByteString> shape()
Graph
public scala.Tuple2<GraphStageLogic,scala.concurrent.Future<Tcp.OutgoingConnection>> createLogicAndMaterializedValue(Attributes inheritedAttributes)
createLogicAndMaterializedValue
in class GraphStageWithMaterializedValue<FlowShape<ByteString,ByteString>,scala.concurrent.Future<Tcp.OutgoingConnection>>
public java.lang.String toString()
toString
in class java.lang.Object