Packages

c

akka.stream.alpakka.mqtt.impl

MqttFlowStageLogic

abstract class MqttFlowStageLogic[I] extends GraphStageLogic with StageLogging with InHandler with OutHandler

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MqttFlowStageLogic
  2. OutHandler
  3. InHandler
  4. StageLogging
  5. GraphStageLogic
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MqttFlowStageLogic(in: Inlet[I], out: Outlet[MqttMessageWithAck], shape: Shape, subscriptionPromise: Promise[Done], connectionSettings: MqttConnectionSettings, subscriptions: Map[String, MqttQoS], bufferSize: Int, defaultQoS: MqttQoS, manualAcks: Boolean)

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[stream]
    Definition Classes
    GraphStageLogic
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def beforePreStart(): Unit
    Attributes
    protected[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[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  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. final def getAsyncCallback[T](handler: (T) ⇒ Unit): AsyncCallback[T]
    Definition Classes
    GraphStageLogic
  34. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  35. def getEagerStageActor(eagerMaterializer: Materializer, poisonPillCompatibility: Boolean)(receive: ((ActorRef, Any)) ⇒ Unit): StageActor
    Attributes
    protected[akka]
    Definition Classes
    GraphStageLogic
    Annotations
    @InternalApi()
  36. final def getHandler(out: Outlet[_]): OutHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  37. final def getHandler(in: Inlet[_]): InHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  38. final def getStageActor(receive: ((ActorRef, Any)) ⇒ Unit): StageActor
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  39. final def grab[T](in: Inlet[T]): T
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  40. def handleDeliveryComplete(token: IMqttDeliveryToken): Unit
    Attributes
    protected
  41. final def hasBeenPulled[T](in: Inlet[T]): Boolean
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  42. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  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() @HotSpotIntrinsicCandidate()
  56. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  57. def onDownstreamFinish(): Unit
    Definition Classes
    MqttFlowStageLogic → OutHandler
  58. def onDownstreamFinish(cause: Throwable): Unit
    Definition Classes
    OutHandler
    Annotations
    @throws( classOf[java.lang.Exception] )
  59. def onPull(): Unit
    Definition Classes
    MqttFlowStageLogic → OutHandler
  60. def onPush(): Unit
    Definition Classes
    MqttFlowStageLogic → InHandler
  61. def onUpstreamFailure(ex: Throwable): Unit
    Definition Classes
    MqttFlowStageLogic → InHandler
  62. def onUpstreamFinish(): Unit
    Definition Classes
    MqttFlowStageLogic → InHandler
  63. val outCount: Int
    Definition Classes
    GraphStageLogic
  64. final def passAlong[Out, In <: Out](from: Inlet[In], to: Outlet[Out], doFinish: Boolean, doFail: Boolean, doPull: Boolean): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  65. def postStop(): Unit
    Definition Classes
    MqttFlowStageLogic → GraphStageLogic
  66. def preStart(): Unit
    Definition Classes
    MqttFlowStageLogic → GraphStageLogic
  67. def publishPending(msg: I): Unit
  68. def publishToMqtt(msg: MqttMessage): IMqttDeliveryToken
  69. final def pull[T](in: Inlet[T]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  70. final def push[T](out: Outlet[T], elem: T): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  71. final def read[T](in: Inlet[T], andThen: Procedure[T], onClose: Effect): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  72. final def read[T](in: Inlet[T])(andThen: (T) ⇒ Unit, onClose: () ⇒ Unit): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  73. final def readN[T](in: Inlet[T], n: Int, andThen: Procedure[List[T]], onClose: Procedure[List[T]]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  74. final def readN[T](in: Inlet[T], n: Int)(andThen: (Seq[T]) ⇒ Unit, onClose: (Seq[T]) ⇒ Unit): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  75. final def setHandler(out: Outlet[_], handler: OutHandler): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  76. final def setHandler(in: Inlet[_], handler: InHandler): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  77. final def setHandlers(in: Inlet[_], out: Outlet[_], handler: InHandler with OutHandler): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  78. final def setKeepGoing(enabled: Boolean): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  79. final def stageActor: StageActor
    Definition Classes
    GraphStageLogic
  80. def stageActorName: String
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  81. def subFusingMaterializer: Materializer
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  82. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  83. def toString(): String
    Definition Classes
    AnyRef → Any
  84. final def totallyIgnorantInput: InHandler
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  85. final def tryPull[T](in: Inlet[T]): Unit
    Attributes
    protected
    Definition Classes
    GraphStageLogic
  86. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  87. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  88. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from OutHandler

Inherited from InHandler

Inherited from StageLogging

Inherited from GraphStageLogic

Inherited from AnyRef

Inherited from Any

Ungrouped