class MqttFlowWithAckStageLogic extends MqttFlowStageLogic[MqttMessageWithAck]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- MqttFlowWithAckStageLogic
- MqttFlowStageLogic
- OutHandler
- InHandler
- StageLogging
- GraphStageLogic
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new MqttFlowWithAckStageLogic(in: Inlet[MqttMessageWithAck], out: Outlet[MqttMessageWithAck], shape: Shape, subscriptionPromise: Promise[Done], connectionSettings: MqttConnectionSettings, subscriptions: Map[String, MqttQoS], bufferSize: Int, defaultQoS: MqttQoS, manualAcks: Boolean)
Type Members
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def abortEmitting(out: Outlet[_]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def abortReading(in: Inlet[_]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- def afterPostStop(): Unit
- Attributes
- protected[stream]
- Definition Classes
- GraphStageLogic
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def beforePreStart(): Unit
- Attributes
- protected[stream]
- Definition Classes
- GraphStageLogic
- final def cancel[T](in: Inlet[T], cause: Throwable): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def cancel[T](in: Inlet[T]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def cancelStage(cause: Throwable): Unit
- Definition Classes
- GraphStageLogic
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def complete[T](out: Outlet[T]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def completeStage(): Unit
- Definition Classes
- GraphStageLogic
- final def conditionalTerminateInput(predicate: () => Boolean): InHandler
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def conditionalTerminateOutput(predicate: () => Boolean): OutHandler
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def createAsyncCallback[T](handler: Procedure[T]): AsyncCallback[T]
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def eagerTerminateInput: InHandler
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def eagerTerminateOutput: OutHandler
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def emit[T](out: Outlet[T], elem: T, andThen: Effect): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def emit[T](out: Outlet[T], elem: T): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def emit[T](out: Outlet[T], elem: T, andThen: () => Unit): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def emitMultiple[T](out: Outlet[T], elems: Iterator[T]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def emitMultiple[T](out: Outlet[T], elems: Iterator[T], andThen: () => Unit): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def emitMultiple[T](out: Outlet[T], elems: Iterator[T], andThen: Effect): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def emitMultiple[T](out: Outlet[T], elems: Iterator[T]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def emitMultiple[T](out: Outlet[T], elems: Iterable[T]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def emitMultiple[T](out: Outlet[T], elems: Iterable[T], andThen: () => Unit): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def fail[T](out: Outlet[T], ex: Throwable): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def failStage(ex: Throwable): Unit
- Definition Classes
- GraphStageLogic
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getAsyncCallback[T](handler: (T) => Unit): AsyncCallback[T]
- Definition Classes
- GraphStageLogic
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getEagerStageActor(eagerMaterializer: Materializer)(receive: ((ActorRef, Any)) => Unit): StageActor
- Attributes
- protected[akka]
- Definition Classes
- GraphStageLogic
- Annotations
- @InternalApi()
- final def getHandler(out: Outlet[_]): OutHandler
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def getHandler(in: Inlet[_]): InHandler
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def getStageActor(receive: ((ActorRef, Any)) => Unit): StageActor
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def grab[T](in: Inlet[T]): T
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- def handleDeliveryComplete(token: IMqttDeliveryToken): Unit
- Definition Classes
- MqttFlowWithAckStageLogic → MqttFlowStageLogic
- final def hasBeenPulled[T](in: Inlet[T]): Boolean
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def ignoreTerminateInput: InHandler
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def ignoreTerminateOutput: OutHandler
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- val inCount: Int
- Definition Classes
- GraphStageLogic
- final def isAvailable[T](out: Outlet[T]): Boolean
- Definition Classes
- GraphStageLogic
- final def isAvailable[T](in: Inlet[T]): Boolean
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def isClosed[T](out: Outlet[T]): Boolean
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def isClosed[T](in: Inlet[T]): Boolean
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def log: LoggingAdapter
- Definition Classes
- StageLogging
- def logSource: Class[_]
- Attributes
- protected
- Definition Classes
- StageLogging
- def materializer: Materializer
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def onDownstreamFinish(cause: Throwable): Unit
- Definition Classes
- MqttFlowStageLogic → OutHandler
- def onPull(): Unit
- Definition Classes
- MqttFlowStageLogic → OutHandler
- def onPush(): Unit
- Definition Classes
- MqttFlowStageLogic → InHandler
- def onUpstreamFailure(ex: Throwable): Unit
- Definition Classes
- MqttFlowStageLogic → InHandler
- def onUpstreamFinish(): Unit
- Definition Classes
- MqttFlowStageLogic → InHandler
- val outCount: Int
- Definition Classes
- GraphStageLogic
- final def passAlong[Out, In <: Out](from: Inlet[In], to: Outlet[Out], doFinish: Boolean, doFail: Boolean, doPull: Boolean): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- def postStop(): Unit
- Definition Classes
- MqttFlowStageLogic → GraphStageLogic
- def preStart(): Unit
- Definition Classes
- MqttFlowStageLogic → GraphStageLogic
- def publishPending(msg: MqttMessageWithAck): Unit
- Definition Classes
- MqttFlowWithAckStageLogic → MqttFlowStageLogic
- def publishToMqtt(msg: MqttMessage): IMqttDeliveryToken
- Definition Classes
- MqttFlowStageLogic
- final def pull[T](in: Inlet[T]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def push[T](out: Outlet[T], elem: T): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def read[T](in: Inlet[T], andThen: Procedure[T], onClose: Effect): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def read[T](in: Inlet[T])(andThen: (T) => Unit, onClose: () => Unit): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def readN[T](in: Inlet[T], n: Int, andThen: Procedure[List[T]], onClose: Procedure[List[T]]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def readN[T](in: Inlet[T], n: Int)(andThen: (Seq[T]) => Unit, onClose: (Seq[T]) => Unit): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def setHandler(out: Outlet[_], handler: OutHandler): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def setHandler(in: Inlet[_], handler: InHandler): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def setHandlers(in: Inlet[_], out: Outlet[_], handler: InHandler with OutHandler): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def setKeepGoing(enabled: Boolean): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def stageActor: StageActor
- Definition Classes
- GraphStageLogic
- def stageActorName: String
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- def subFusingMaterializer: Materializer
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- GraphStageLogic → AnyRef → Any
- final def totallyIgnorantInput: InHandler
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def tryPull[T](in: Inlet[T]): Unit
- Attributes
- protected
- Definition Classes
- GraphStageLogic
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()