class UdpConnectedFlow extends GraphStage[FlowShape[ByteString, ByteString]]

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. UdpConnectedFlow
  2. GraphStage
  3. GraphStageWithMaterializedValue
  4. Graph
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new UdpConnectedFlow(remoteAddress: InetSocketAddress, localAddress: Option[InetSocketAddress], connectOptions: Iterable[SocketOption])(implicit system: ActorSystem[Nothing])

Type Members

  1. type Shape = FlowShape[ByteString, ByteString]
    Definition Classes
    Graph

Value Members

  1. def addAttributes(attr: Attributes): Graph[FlowShape[ByteString, ByteString], NotUsed]
    Definition Classes
    Graph
  2. def async(dispatcher: String, inputBufferSize: Int): Graph[FlowShape[ByteString, ByteString], NotUsed]
    Definition Classes
    Graph
  3. def async(dispatcher: String): Graph[FlowShape[ByteString, ByteString], NotUsed]
    Definition Classes
    Graph
  4. def async: Graph[FlowShape[ByteString, ByteString], NotUsed]
    Definition Classes
    Graph
  5. def createLogic(inheritedAttributes: Attributes): GraphStageLogic
    Definition Classes
    UdpConnectedFlow → GraphStage
  6. final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
    Definition Classes
    GraphStage → GraphStageWithMaterializedValue
  7. val in: Inlet[ByteString]
  8. def named(name: String): Graph[FlowShape[ByteString, ByteString], NotUsed]
    Definition Classes
    Graph
  9. val out: Outlet[ByteString]
  10. def shape: FlowShape[ByteString, ByteString]
    Definition Classes
    UdpConnectedFlow → Graph
  11. final def withAttributes(attr: Attributes): Graph[FlowShape[ByteString, ByteString], NotUsed]
    Definition Classes
    GraphStageWithMaterializedValue → Graph