object ActorPublisherMessage
- Alphabetic
- By Inheritance
- ActorPublisherMessage
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- sealed abstract class Cancel extends ActorPublisherMessage
-
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
- sealed abstract class SubscriptionTimeoutExceeded extends ActorPublisherMessage
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
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
cancelInstance: Cancel.type
Java API: get the singleton instance of the
Cancel
message -
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
subscriptionTimeoutExceededInstance: SubscriptionTimeoutExceeded.type
Java API: get the singleton instance of the
SubscriptionTimeoutExceeded
message -
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
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.
-
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.