Packages

o

lerna.util.akka.stream.FailureSkipFlow

FailureSkipFlowLogic

object FailureSkipFlowLogic extends GraphStageLogicWithLogging

Annotations
@SuppressWarnings()
Linear Supertypes
GraphStageLogicWithLogging, StageLogging, GraphStageLogic, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FailureSkipFlowLogic
  2. GraphStageLogicWithLogging
  3. StageLogging
  4. GraphStageLogic
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. class SubSinkInlet[T] extends AnyRef
    Definition Classes
    GraphStageLogic
  2. class SubSourceOutlet[T] extends AnyRef
    Definition Classes
    GraphStageLogic

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def abortEmitting(out: Outlet[_]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  5. final def abortReading(in: Inlet[_]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  6. def afterPostStop(): Unit
    Attributes
    protected[akka.stream]
    Definition Classes
    GraphStageLogic
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def beforePreStart(): Unit
    Attributes
    protected[akka.stream]
    Definition Classes
    GraphStageLogic
  9. final def cancel[T](in: Inlet[T], cause: Throwable): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  10. final def cancel[T](in: Inlet[T]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  11. final def cancelStage(cause: Throwable): Unit
    Definition Classes
    GraphStageLogic
  12. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  13. final def complete[T](out: Outlet[T]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  14. final def completeStage(): Unit
    Definition Classes
    GraphStageLogic
  15. final def conditionalTerminateInput(predicate: () ⇒ Boolean): InHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  16. final def conditionalTerminateOutput(predicate: () ⇒ Boolean): OutHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  17. final def createAsyncCallback[T](handler: Procedure[T]): AsyncCallback[T]
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  18. final def eagerTerminateInput: InHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  19. final def eagerTerminateOutput: OutHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  20. final def emit[T](out: Outlet[T], elem: T, andThen: Effect): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  21. final def emit[T](out: Outlet[T], elem: T): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  22. final def emit[T](out: Outlet[T], elem: T, andThen: () ⇒ Unit): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  23. final def emitMultiple[T](out: Outlet[T], elems: Iterator[T]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  24. final def emitMultiple[T](out: Outlet[T], elems: Iterator[T], andThen: () ⇒ Unit): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  25. final def emitMultiple[T](out: Outlet[T], elems: Iterator[T], andThen: Effect): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  26. final def emitMultiple[T](out: Outlet[T], elems: Iterator[T]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  27. final def emitMultiple[T](out: Outlet[T], elems: Iterable[T]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  28. final def emitMultiple[T](out: Outlet[T], elems: Iterable[T], andThen: () ⇒ Unit): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  29. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  30. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  31. final def fail[T](out: Outlet[T], ex: Throwable): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  32. final def failStage(ex: Throwable): Unit
    Definition Classes
    GraphStageLogic
  33. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  34. final def getAsyncCallback[T](handler: (T) ⇒ Unit): AsyncCallback[T]
    Definition Classes
    GraphStageLogic
  35. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  36. def getEagerStageActor(eagerMaterializer: Materializer, poisonPillCompatibility: Boolean)(receive: ((ActorRef, Any)) ⇒ Unit): StageActor
    Attributes
    protected[akka]
    Definition Classes
    GraphStageLogic
    Annotations
    @InternalApi()
  37. final def getHandler(out: Outlet[_]): OutHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  38. final def getHandler(in: Inlet[_]): InHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  39. final def getStageActor(receive: ((ActorRef, Any)) ⇒ Unit): StageActor
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  40. final def grab[T](in: Inlet[T]): T
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  41. final def hasBeenPulled[T](in: Inlet[T]): Boolean
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  42. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  43. final def ignoreTerminateInput: InHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  44. final def ignoreTerminateOutput: OutHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  45. val inCount: Int
    Definition Classes
    GraphStageLogic
  46. final def isAvailable[T](out: Outlet[T]): Boolean
    Definition Classes
    GraphStageLogic
  47. final def isAvailable[T](in: Inlet[T]): Boolean
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  48. final def isClosed[T](out: Outlet[T]): Boolean
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  49. final def isClosed[T](in: Inlet[T]): Boolean
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  50. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  51. def log: LoggingAdapter
    Definition Classes
    StageLogging
  52. def logSource: Class[_]
    Attributes
    protected
    Definition Classes
    StageLogging
  53. def materializer: Materializer
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  54. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  55. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  56. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  57. val outCount: Int
    Definition Classes
    GraphStageLogic
  58. final def passAlong[Out, In <: Out](from: Inlet[In], to: Outlet[Out], doFinish: Boolean, doFail: Boolean, doPull: Boolean): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  59. def postStop(): Unit
    Definition Classes
    GraphStageLogic
    Annotations
    @throws( classOf[java.lang.Exception] )
  60. def preStart(): Unit
    Definition Classes
    FailureSkipFlowLogic → GraphStageLogic
  61. final def pull[T](in: Inlet[T]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  62. final def push[T](out: Outlet[T], elem: T): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  63. final def read[T](in: Inlet[T], andThen: Procedure[T], onClose: Effect): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  64. final def read[T](in: Inlet[T])(andThen: (T) ⇒ Unit, onClose: () ⇒ Unit): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  65. final def readN[T](in: Inlet[T], n: Int, andThen: Procedure[List[T]], onClose: Procedure[List[T]]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  66. final def readN[T](in: Inlet[T], n: Int)(andThen: (Seq[T]) ⇒ Unit, onClose: (Seq[T]) ⇒ Unit): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  67. final def setHandler(out: Outlet[_], handler: OutHandler): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  68. final def setHandler(in: Inlet[_], handler: InHandler): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  69. final def setHandlers(in: Inlet[_], out: Outlet[_], handler: InHandler with OutHandler): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  70. final def setKeepGoing(enabled: Boolean): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  71. final def stageActor: StageActor
    Definition Classes
    GraphStageLogic
  72. def stageActorName: String
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  73. def subFusingMaterializer: Materializer
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  74. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  75. def toString(): String
    Definition Classes
    AnyRef → Any
  76. final def totallyIgnorantInput: InHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  77. final def tryPull[T](in: Inlet[T]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  78. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  79. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  80. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from GraphStageLogicWithLogging

Inherited from StageLogging

Inherited from GraphStageLogic

Inherited from AnyRef

Inherited from Any

Ungrouped