public static class PoolConductor.Ports
extends akka.stream.Shape
implements scala.Product, scala.Serializable
Constructor and Description |
---|
Ports(akka.stream.Inlet<PoolFlow.RequestContext> requestIn,
akka.stream.Inlet<PoolSlot.RawSlotEvent> slotEventIn,
scala.collection.immutable.Seq<akka.stream.Outlet<PoolConductor.SlotCommand>> slotOuts) |
Modifier and Type | Method and Description |
---|---|
akka.stream.Shape |
copyFromPorts(scala.collection.immutable.Seq<akka.stream.Inlet<?>> inlets,
scala.collection.immutable.Seq<akka.stream.Outlet<?>> outlets)
Needs to be implemented for 2.4.
|
akka.stream.Shape |
deepCopy() |
scala.collection.immutable.List<akka.stream.Inlet<? super PoolSlot.RawSlotEvent>> |
inlets() |
scala.collection.immutable.Seq<akka.stream.Outlet<PoolConductor.SlotCommand>> |
outlets() |
akka.stream.Inlet<PoolFlow.RequestContext> |
requestIn() |
akka.stream.Inlet<PoolSlot.RawSlotEvent> |
slotEventIn() |
scala.collection.immutable.Seq<akka.stream.Outlet<PoolConductor.SlotCommand>> |
slotOuts() |
getInlets, getOutlets, hasSamePortsAndShapeAs, hasSamePortsAs, requireSamePortsAndShapeAs, requireSamePortsAs
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public Ports(akka.stream.Inlet<PoolFlow.RequestContext> requestIn, akka.stream.Inlet<PoolSlot.RawSlotEvent> slotEventIn, scala.collection.immutable.Seq<akka.stream.Outlet<PoolConductor.SlotCommand>> slotOuts)
public akka.stream.Inlet<PoolFlow.RequestContext> requestIn()
public akka.stream.Inlet<PoolSlot.RawSlotEvent> slotEventIn()
public scala.collection.immutable.Seq<akka.stream.Outlet<PoolConductor.SlotCommand>> slotOuts()
public scala.collection.immutable.List<akka.stream.Inlet<? super PoolSlot.RawSlotEvent>> inlets()
public scala.collection.immutable.Seq<akka.stream.Outlet<PoolConductor.SlotCommand>> outlets()
public akka.stream.Shape deepCopy()
deepCopy
in class akka.stream.Shape
public akka.stream.Shape copyFromPorts(scala.collection.immutable.Seq<akka.stream.Inlet<?>> inlets, scala.collection.immutable.Seq<akka.stream.Outlet<?>> outlets)
copyFromPorts
in class akka.stream.Shape
inlets
- (undocumented)outlets
- (undocumented)