root
API
Generated with
root/cps/cps.stream/BaseUnfoldCpsAsyncEmitAbsorber/State

State

cps.stream.BaseUnfoldCpsAsyncEmitAbsorber.State
class State

Attributes

Source
BaseUnfoldCpsAsyncEmitAbsorber.scala
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def finish(r: Try[Unit]): Unit
def queueEmit(v: T): F[Unit]

Concrete fields

final val StageBusy: 1
final val StageContinue: 3
final val StageFree: 0
val consumerEvents: ConcurrentLinkedDeque[Promise[SupplyEventRecord]]
val emitStart: AtomicBoolean
val finishRef: AtomicReference[Try[Unit]]
val stepStage: AtomicInteger
val supplyEvents: ConcurrentLinkedDeque[SupplyEventRecord]
Generated with