object Receiver
Ordering
- Alphabetic
- By Inheritance
Inherited
- Receiver
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Type Members
- sealed trait Command [T] extends InternalCommand[T]
-
final
case class
ExternalAddress
[T](replyTo: ActorRef[ActorRef[T]]) extends Command[T] with Product with Serializable
Retrieve the external address of this Receiver (i.e.
Retrieve the external address of this Receiver (i.e. the side at which it takes in the messages of type T.
-
final
case class
GetAll
[T](timeout: FiniteDuration)(replyTo: ActorRef[GetAllResult[T]]) extends Command[T] with Product with Serializable
Retrieve all messages from the Receiver that it has queued after the given duration has elapsed.
- final case class GetAllResult [T](receiver: ActorRef[Command[T]], msgs: Seq[T]) extends Replies[T] with Product with Serializable
-
final
case class
GetOne
[T](timeout: FiniteDuration)(replyTo: ActorRef[GetOneResult[T]]) extends Command[T] with Product with Serializable
Retrieve one message from the Receiver, waiting at most for the given duration.
- final case class GetOneResult [T](receiver: ActorRef[Command[T]], msg: Option[T]) extends Replies[T] with Product with Serializable
- sealed trait InternalCommand [T] extends AnyRef
- case class ReceiveTimeout [T]() extends InternalCommand[T] with Product with Serializable
- sealed trait Replies [T] extends AnyRef
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 behavior[T]: Behavior[Command[T]]
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )