object FanIn

INTERNAL API

Source
FanIn.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FanIn
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. abstract class InputBunch extends AnyRef
  2. final case class OnComplete (id: Int) extends DeadLetterSuppression with NoSerializationVerificationNeeded with Product with Serializable
  3. final case class OnError (id: Int, cause: Throwable) extends DeadLetterSuppression with NoSerializationVerificationNeeded with Product with Serializable
  4. final case class OnNext (id: Int, e: Any) extends DeadLetterSuppression with NoSerializationVerificationNeeded with Product with Serializable
  5. final case class OnSubscribe (id: Int, subscription: Subscription) extends DeadLetterSuppression with NoSerializationVerificationNeeded with Product with Serializable
  6. type State = Byte
  7. final case class SubInput [T](impl: ActorRef, id: Int) extends Subscriber[T] with Product with Serializable

Value Members

  1. final val Cancelled: Int(16)
  2. final val Completed: Int(8)
  3. final val Depleted: Int(4)
  4. final val Marked: Int(1)
  5. final val Pending: Int(2)