c

akka.stream.impl.fusing

SupervisedGraphStageLogic

abstract class SupervisedGraphStageLogic extends GraphStageLogic

INTERNAL API

Source
Ops.scala
Linear Supertypes
GraphStageLogic, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SupervisedGraphStageLogic
  2. GraphStageLogic
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SupervisedGraphStageLogic(inheritedAttributes: Attributes, shape: Shape)

Type Members

  1. class SubSinkInlet [T] extends AnyRef

    INTERNAL API

    INTERNAL API

    This allows the dynamic creation of an Inlet for a GraphStage which is connected to a Sink that is available for materialization (e.g. using the subFusingMaterializer). Care needs to be taken to cancel this Inlet when the stage shuts down lest the corresponding Sink be left hanging.

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

    INTERNAL API

    INTERNAL API

    This allows the dynamic creation of an Outlet for a GraphStage which is connected to a Source that is available for materialization (e.g. using the subFusingMaterializer). Care needs to be taken to complete this Outlet when the stage shuts down lest the corresponding Sink be left hanging. It is good practice to use the timeout method to cancel this Outlet in case the corresponding Source is not materialized within a given time limit, see e.g. ActorMaterializerSettings.

    Definition Classes
    GraphStageLogic

Abstract Value Members

  1. abstract def onResume(t: Throwable): Unit

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. def +(other: String): String
    Implicit
    This member is added by an implicit conversion from SupervisedGraphStageLogic to any2stringadd[SupervisedGraphStageLogic] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (SupervisedGraphStageLogic, B)
    Implicit
    This member is added by an implicit conversion from SupervisedGraphStageLogic to ArrowAssoc[SupervisedGraphStageLogic] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. final def abortEmitting(out: Outlet[_]): Unit

    Abort outstanding (suspended) emissions for the given outlet, if there are any.

    Abort outstanding (suspended) emissions for the given outlet, if there are any. This will reinstall the replaced handler that was in effect before the emit call.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  7. final def abortReading(in: Inlet[_]): Unit

    Abort outstanding (suspended) reading for the given inlet, if there is any.

    Abort outstanding (suspended) reading for the given inlet, if there is any. This will reinstall the replaced handler that was in effect before the read call.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  8. def afterPostStop(): Unit

    INTERNAL API

    INTERNAL API

    Attributes
    protected[akka.stream]
    Definition Classes
    GraphStageLogic
  9. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  10. def beforePreStart(): Unit

    INTERNAL API

    INTERNAL API

    Attributes
    protected[akka.stream]
    Definition Classes
    GraphStageLogic
  11. final def cancel[T](in: Inlet[T]): Unit

    Requests to stop receiving events from a given input port.

    Requests to stop receiving events from a given input port. Cancelling clears any ungrabbed elements from the port.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  12. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. final def complete[T](out: Outlet[T]): Unit

    Signals that there will be no more elements emitted on the given port.

    Signals that there will be no more elements emitted on the given port.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  14. final def completeStage(): Unit

    Automatically invokes cancel() or complete() on all the input or output ports that have been called, then marks the stage as stopped.

    Automatically invokes cancel() or complete() on all the input or output ports that have been called, then marks the stage as stopped.

    Definition Classes
    GraphStageLogic
  15. final def conditionalTerminateInput(predicate: () ⇒ Boolean): InHandler

    Input handler that terminates the state upon receiving completion if the given condition holds at that time.

    Input handler that terminates the state upon receiving completion if the given condition holds at that time. The stage fails upon receiving a failure.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  16. final def conditionalTerminateOutput(predicate: () ⇒ Boolean): OutHandler

    Output handler that terminates the state upon receiving completion if the given condition holds at that time.

    Output handler that terminates the state upon receiving completion if the given condition holds at that time. The stage fails upon receiving a failure.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  17. final def createAsyncCallback[T](handler: Procedure[T]): AsyncCallback[T]

    Java API: Obtain a callback object that can be used asynchronously to re-enter the current GraphStage with an asynchronous notification.

    Java API: Obtain a callback object that can be used asynchronously to re-enter the current GraphStage with an asynchronous notification. The invoke() method of the returned AsyncCallback is safe to be called from other threads and it will in the background thread-safely delegate to the passed callback function. I.e. invoke() will be called by the external world and the passed handler will be invoked eventually in a thread-safe way by the execution environment.

    This object can be cached and reused within the same GraphStageLogic.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  18. final def eagerTerminateInput: InHandler

    Input handler that terminates the stage upon receiving completion.

    Input handler that terminates the stage upon receiving completion. The stage fails upon receiving a failure.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  19. final def eagerTerminateOutput: OutHandler

    Output handler that terminates the stage upon cancellation.

    Output handler that terminates the stage upon cancellation.

    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

    Emit an element through the given outlet, suspending execution if necessary.

    Emit an element through the given outlet, suspending execution if necessary. This action replaces the OutHandler for the given outlet if suspension is needed and reinstalls the current handler upon receiving an onPull() signal.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  22. final def emit[T](out: Outlet[T], elem: T, andThen: () ⇒ Unit): Unit

    Emit an element through the given outlet and continue with the given thunk afterwards, suspending execution if necessary.

    Emit an element through the given outlet and continue with the given thunk afterwards, suspending execution if necessary. This action replaces the OutHandler for the given outlet if suspension is needed and reinstalls the current handler upon receiving an onPull() signal (before invoking the andThen function).

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  23. final def emitMultiple[T](out: Outlet[T], elems: Iterator[T]): Unit

    Emit a sequence of elements through the given outlet, suspending execution if necessary.

    Emit a sequence of elements through the given outlet, suspending execution if necessary. This action replaces the OutHandler for the given outlet if suspension is needed and reinstalls the current handler upon receiving an onPull() signal.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  24. final def emitMultiple[T](out: Outlet[T], elems: Iterator[T], andThen: () ⇒ Unit): Unit

    Emit a sequence of elements through the given outlet and continue with the given thunk afterwards, suspending execution if necessary.

    Emit a sequence of elements through the given outlet and continue with the given thunk afterwards, suspending execution if necessary. This action replaces the OutHandler for the given outlet if suspension is needed and reinstalls the current handler upon receiving an onPull() signal (before invoking the andThen function).

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  25. final def emitMultiple[T](out: Outlet[T], elems: Iterator[T], andThen: Effect): Unit

    Java API

    Java API

    Emit a sequence of elements through the given outlet, suspending execution if necessary. This action replaces the AbstractOutHandler for the given outlet if suspension is needed and reinstalls the current handler upon receiving an onPull() signal.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  26. final def emitMultiple[T](out: Outlet[T], elems: Iterator[T]): Unit

    Java API

    Java API

    Emit a sequence of elements through the given outlet, suspending execution if necessary. This action replaces the AbstractOutHandler for the given outlet if suspension is needed and reinstalls the current handler upon receiving an onPull() signal.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  27. final def emitMultiple[T](out: Outlet[T], elems: Iterable[T]): Unit

    Emit a sequence of elements through the given outlet, suspending execution if necessary.

    Emit a sequence of elements through the given outlet, suspending execution if necessary. This action replaces the OutHandler for the given outlet if suspension is needed and reinstalls the current handler upon receiving an onPull() signal.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  28. final def emitMultiple[T](out: Outlet[T], elems: Iterable[T], andThen: () ⇒ Unit): Unit

    Emit a sequence of elements through the given outlet and continue with the given thunk afterwards, suspending execution if necessary.

    Emit a sequence of elements through the given outlet and continue with the given thunk afterwards, suspending execution if necessary. This action replaces the OutHandler for the given outlet if suspension is needed and reinstalls the current handler upon receiving an onPull() signal (before invoking the andThen function).

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  29. def ensuring(cond: (SupervisedGraphStageLogic) ⇒ Boolean, msg: ⇒ Any): SupervisedGraphStageLogic
    Implicit
    This member is added by an implicit conversion from SupervisedGraphStageLogic to Ensuring[SupervisedGraphStageLogic] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  30. def ensuring(cond: (SupervisedGraphStageLogic) ⇒ Boolean): SupervisedGraphStageLogic
    Implicit
    This member is added by an implicit conversion from SupervisedGraphStageLogic to Ensuring[SupervisedGraphStageLogic] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  31. def ensuring(cond: Boolean, msg: ⇒ Any): SupervisedGraphStageLogic
    Implicit
    This member is added by an implicit conversion from SupervisedGraphStageLogic to Ensuring[SupervisedGraphStageLogic] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  32. def ensuring(cond: Boolean): SupervisedGraphStageLogic
    Implicit
    This member is added by an implicit conversion from SupervisedGraphStageLogic to Ensuring[SupervisedGraphStageLogic] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  33. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  34. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  35. final def fail[T](out: Outlet[T], ex: Throwable): Unit

    Signals failure through the given port.

    Signals failure through the given port.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  36. final def failStage(ex: Throwable): Unit

    Automatically invokes cancel() or fail() on all the input or output ports that have been called, then marks the stage as stopped.

    Automatically invokes cancel() or fail() on all the input or output ports that have been called, then marks the stage as stopped.

    Definition Classes
    GraphStageLogic
  37. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  38. def formatted(fmtstr: String): String
    Implicit
    This member is added by an implicit conversion from SupervisedGraphStageLogic to StringFormat[SupervisedGraphStageLogic] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  39. final def getAsyncCallback[T](handler: (T) ⇒ Unit): AsyncCallback[T]

    Obtain a callback object that can be used asynchronously to re-enter the current GraphStage with an asynchronous notification.

    Obtain a callback object that can be used asynchronously to re-enter the current GraphStage with an asynchronous notification. The invoke() method of the returned AsyncCallback is safe to be called from other threads and it will in the background thread-safely delegate to the passed callback function. I.e. invoke() will be called by the external world and the passed handler will be invoked eventually in a thread-safe way by the execution environment.

    This object can be cached and reused within the same GraphStageLogic.

    Definition Classes
    GraphStageLogic
  40. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  41. final def getHandler(out: Outlet[_]): OutHandler

    Retrieves the current callback for the events on the given Outlet

    Retrieves the current callback for the events on the given Outlet

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  42. final def getHandler(in: Inlet[_]): InHandler

    Retrieves the current callback for the events on the given Inlet

    Retrieves the current callback for the events on the given Inlet

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  43. final def getStageActor(receive: ((ActorRef, Any)) ⇒ Unit): StageActor

    Initialize a StageActorRef which can be used to interact with from the outside world "as-if" an Actor.

    Initialize a StageActorRef which can be used to interact with from the outside world "as-if" an Actor. The messages are looped through the getAsyncCallback mechanism of GraphStage so they are safe to modify internal state of this stage.

    This method must (the earliest) be called after the GraphStageLogic constructor has finished running, for example from the preStart callback the graph stage logic provides.

    Created StageActorRef to get messages and watch other actors in synchronous way.

    The StageActorRef's lifecycle is bound to the Stage, in other words when the Stage is finished, the Actor will be terminated as well. The entity backing the StageActorRef is not a real Actor, but the GraphStageLogic itself, therefore it does not react to PoisonPill.

    receive

    callback that will be called upon receiving of a message by this special Actor

    returns

    minimal actor with watch method

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  44. final def grab[T](in: Inlet[T]): T

    Once the callback InHandler.onPush() for an input port has been invoked, the element that has been pushed can be retrieved via this method.

    Once the callback InHandler.onPush() for an input port has been invoked, the element that has been pushed can be retrieved via this method. After grab() has been called the port is considered to be empty, and further calls to grab() will fail until the port is pulled again and a new element is pushed as a response.

    The method isAvailable() can be used to query if the port has an element that can be grabbed or not.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  45. final def hasBeenPulled[T](in: Inlet[T]): Boolean

    Indicates whether there is already a pending pull for the given input port.

    Indicates whether there is already a pending pull for the given input port. If this method returns true then isAvailable() must return false for that same port.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  46. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  47. final def ignoreTerminateInput: InHandler

    Input handler that does not terminate the stage upon receiving completion.

    Input handler that does not terminate the stage upon receiving completion. The stage fails upon receiving a failure.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  48. final def ignoreTerminateOutput: OutHandler

    Output handler that does not terminate the stage upon cancellation.

    Output handler that does not terminate the stage upon cancellation.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  49. val inCount: Int
    Definition Classes
    GraphStageLogic
  50. final def isAvailable[T](out: Outlet[T]): Boolean

    Return true if the given output port is ready to be pushed.

    Return true if the given output port is ready to be pushed.

    Definition Classes
    GraphStageLogic
  51. final def isAvailable[T](in: Inlet[T]): Boolean

    Indicates whether there is an element waiting at the given input port.

    Indicates whether there is an element waiting at the given input port. grab() can be used to retrieve the element. After calling grab() this method will return false.

    If this method returns true then hasBeenPulled() will return false for that same port.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  52. final def isClosed[T](out: Outlet[T]): Boolean

    Indicates whether the port has been closed.

    Indicates whether the port has been closed. A closed port cannot be pushed.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  53. final def isClosed[T](in: Inlet[T]): Boolean

    Indicates whether the port has been closed.

    Indicates whether the port has been closed. A closed port cannot be pulled.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  54. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  55. def materializer: Materializer

    The akka.stream.Materializer that has set this GraphStage in motion.

    The akka.stream.Materializer that has set this GraphStage in motion.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  56. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  57. final def notify(): Unit
    Definition Classes
    AnyRef
  58. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  59. def onRestart(t: Throwable): Unit
  60. def onStop(t: Throwable): Unit
  61. val outCount: Int
    Definition Classes
    GraphStageLogic
  62. final def passAlong[Out, In <: Out](from: Inlet[In], to: Outlet[Out], doFinish: Boolean = true, doFail: Boolean = true, doPull: Boolean = false): Unit

    Install a handler on the given inlet that emits received elements on the given outlet before pulling for more data.

    Install a handler on the given inlet that emits received elements on the given outlet before pulling for more data. doFinish and doFail control whether completion or failure of the given inlet shall lead to stage termination or not. doPull instructs to perform one initial pull on the from port.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  63. def postStop(): Unit

    Invoked after processing of external events stopped because the stage is about to stop or fail.

    Invoked after processing of external events stopped because the stage is about to stop or fail.

    Definition Classes
    GraphStageLogic
    Annotations
    @throws( classOf[Exception] )
  64. def preStart(): Unit

    Invoked before any external events are processed, at the startup of the stage.

    Invoked before any external events are processed, at the startup of the stage.

    Definition Classes
    GraphStageLogic
    Annotations
    @throws( classOf[Exception] )
  65. final def pull[T](in: Inlet[T]): Unit

    Requests an element on the given port.

    Requests an element on the given port. Calling this method twice before an element arrived will fail. There can only be one outstanding request at any given time. The method hasBeenPulled() can be used query whether pull is allowed to be called or not. This method will also fail if the port is already closed.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  66. final def push[T](out: Outlet[T], elem: T): Unit

    Emits an element through the given output port.

    Emits an element through the given output port. Calling this method twice before a pull() has been arrived will fail. There can be only one outstanding push request at any given time. The method isAvailable() can be used to check if the port is ready to be pushed or not.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  67. final def read[T](in: Inlet[T], andThen: Procedure[T], onClose: Effect): Unit

    Java API: Read an element from the given inlet and continue with the given function, suspending execution if necessary.

    Java API: Read an element from the given inlet and continue with the given function, suspending execution if necessary. This action replaces the InHandler for the given inlet if suspension is needed and reinstalls the current handler upon receiving the onPush() signal (before invoking the andThen function).

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  68. final def read[T](in: Inlet[T])(andThen: (T) ⇒ Unit, onClose: () ⇒ Unit): Unit

    Read an element from the given inlet and continue with the given function, suspending execution if necessary.

    Read an element from the given inlet and continue with the given function, suspending execution if necessary. This action replaces the InHandler for the given inlet if suspension is needed and reinstalls the current handler upon receiving the onPush() signal (before invoking the andThen function).

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  69. final def readN[T](in: Inlet[T], n: Int, andThen: Procedure[List[T]], onClose: Procedure[List[T]]): Unit

    Java API: Read a number of elements from the given inlet and continue with the given function, suspending execution if necessary.

    Java API: Read a number of elements from the given inlet and continue with the given function, suspending execution if necessary. This action replaces the InHandler for the given inlet if suspension is needed and reinstalls the current handler upon receiving the last onPush() signal (before invoking the andThen function).

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  70. final def readN[T](in: Inlet[T], n: Int)(andThen: (Seq[T]) ⇒ Unit, onClose: (Seq[T]) ⇒ Unit): Unit

    Read a number of elements from the given inlet and continue with the given function, suspending execution if necessary.

    Read a number of elements from the given inlet and continue with the given function, suspending execution if necessary. This action replaces the InHandler for the given inlet if suspension is needed and reinstalls the current handler upon receiving the last onPush() signal.

    If upstream closes before N elements have been read, the onClose function is invoked with the elements which were read.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  71. final def setHandler(out: Outlet[_], handler: OutHandler): Unit

    Assigns callbacks for the events for an Outlet

    Assigns callbacks for the events for an Outlet

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  72. final def setHandler(in: Inlet[_], handler: InHandler): Unit

    Assigns callbacks for the events for an Inlet

    Assigns callbacks for the events for an Inlet

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  73. final def setHandlers(in: Inlet[_], out: Outlet[_], handler: InHandler with OutHandler): Unit

    Assign callbacks for linear stage for both Inlet and Outlet

    Assign callbacks for linear stage for both Inlet and Outlet

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  74. final def setKeepGoing(enabled: Boolean): Unit

    Controls whether this stage shall shut down when all its ports are closed, which is the default.

    Controls whether this stage shall shut down when all its ports are closed, which is the default. In order to have it keep going past that point this method needs to be called with a true argument before all ports are closed, and afterwards it will not be closed until this method is called with a false argument or the stage is terminated via completeStage() or failStage().

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  75. final def stageActor: StageActor
    Definition Classes
    GraphStageLogic
  76. def subFusingMaterializer: Materializer

    An akka.stream.Materializer that may run fusable parts of the graphs that it materializes within the same actor as the current GraphStage (if fusing is available).

    An akka.stream.Materializer that may run fusable parts of the graphs that it materializes within the same actor as the current GraphStage (if fusing is available). This materializer must not be shared outside of the GraphStage.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  77. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  78. def toString(): String
    Definition Classes
    AnyRef → Any
  79. final def totallyIgnorantInput: InHandler

    Input handler that does not terminate the stage upon receiving completion nor failure.

    Input handler that does not terminate the stage upon receiving completion nor failure.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  80. final def tryPull[T](in: Inlet[T]): Unit

    Requests an element on the given port unless the port is already closed.

    Requests an element on the given port unless the port is already closed. Calling this method twice before an element arrived will fail. There can only be one outstanding request at any given time. The method hasBeenPulled() can be used query whether pull is allowed to be called or not.

    Attributes
    protected
    Definition Classes
    GraphStageLogic
  81. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  82. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  83. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  84. def withSupervision[T](f: () ⇒ T): Option[T]
  85. def →[B](y: B): (SupervisedGraphStageLogic, B)
    Implicit
    This member is added by an implicit conversion from SupervisedGraphStageLogic to ArrowAssoc[SupervisedGraphStageLogic] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from GraphStageLogic

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from SupervisedGraphStageLogic to any2stringadd[SupervisedGraphStageLogic]

Inherited by implicit conversion StringFormat from SupervisedGraphStageLogic to StringFormat[SupervisedGraphStageLogic]

Inherited by implicit conversion Ensuring from SupervisedGraphStageLogic to Ensuring[SupervisedGraphStageLogic]

Inherited by implicit conversion ArrowAssoc from SupervisedGraphStageLogic to ArrowAssoc[SupervisedGraphStageLogic]

Ungrouped