object ActorPublisherMessage

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ActorPublisherMessage
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. sealed abstract class Cancel extends ActorPublisherMessage
  2. final case class Request(n: Long) extends ActorPublisherMessage with NoSerializationVerificationNeeded with Product with Serializable

    This message is delivered to the ActorPublisher actor when the stream subscriber requests more elements.

    This message is delivered to the ActorPublisher actor when the stream subscriber requests more elements.

    n

    number of requested elements

  3. sealed abstract class SubscriptionTimeoutExceeded extends ActorPublisherMessage

Value Members

  1. def cancelInstance: Cancel.type

    Java API: get the singleton instance of the Cancel message

  2. def subscriptionTimeoutExceededInstance: SubscriptionTimeoutExceeded.type

    Java API: get the singleton instance of the SubscriptionTimeoutExceeded message

  3. object Cancel extends Cancel with NoSerializationVerificationNeeded with Product with Serializable

    This message is delivered to the ActorPublisher actor when the stream subscriber cancels the subscription.

  4. object SubscriptionTimeoutExceeded extends SubscriptionTimeoutExceeded with NoSerializationVerificationNeeded with Product with Serializable

    This message is delivered to the ActorPublisher actor in order to signal the exceeding of an subscription timeout.

    This message is delivered to the ActorPublisher actor in order to signal the exceeding of an subscription timeout. Once the actor receives this message, this publisher will already be in canceled state, thus the actor should clean-up and stop itself.