class IPDiscoveryFlow extends GraphStageWithMaterializedValue[FlowShape[ByteString, ByteString], Future[FoundIP]]

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

Instance Constructors

  1. new IPDiscoveryFlow(openValve: () => Unit)

Type Members

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

Value Members

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