final class MessageBufferMap[I] extends AnyRef
A non thread safe mutable message buffer map that can be used to buffer messages inside actors.
- I
(Id type)
- Source
- MessageBuffer.scala
- Alphabetic
- By Inheritance
- MessageBufferMap
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new MessageBufferMap()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- Implicit
- This member is added by an implicit conversion from MessageBufferMap[I] toany2stringadd[MessageBufferMap[I]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
- def ->[B](y: B): (MessageBufferMap[I], B)
- Implicit
- This member is added by an implicit conversion from MessageBufferMap[I] toArrowAssoc[MessageBufferMap[I]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def add(id: I): Unit
Add an id to the buffer map
- def append(id: I, message: Any, ref: ActorRef): Unit
Append an element to the buffer for an id.
Append an element to the buffer for an id.
- id
the id to add the element to
- message
the message to buffer
- ref
the actor to buffer
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def contains(id: I): Boolean
Check if the buffer map contains an id.
Check if the buffer map contains an id.
- id
the id to check for
- returns
if the buffer contains the given id
- def drop(id: I, reason: String, deadLetters: ActorRef): Int
Remove the buffer for an id, but publish a akka.actor.Dropped for each dropped buffered message
Remove the buffer for an id, but publish a akka.actor.Dropped for each dropped buffered message
- returns
how many buffered messages were dropped
- def ensuring(cond: (MessageBufferMap[I]) => Boolean, msg: => Any): MessageBufferMap[I]
- Implicit
- This member is added by an implicit conversion from MessageBufferMap[I] toEnsuring[MessageBufferMap[I]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: (MessageBufferMap[I]) => Boolean): MessageBufferMap[I]
- Implicit
- This member is added by an implicit conversion from MessageBufferMap[I] toEnsuring[MessageBufferMap[I]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean, msg: => Any): MessageBufferMap[I]
- Implicit
- This member is added by an implicit conversion from MessageBufferMap[I] toEnsuring[MessageBufferMap[I]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean): MessageBufferMap[I]
- Implicit
- This member is added by an implicit conversion from MessageBufferMap[I] toEnsuring[MessageBufferMap[I]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def forEach(f: Procedure2[I, MessageBuffer]): Unit
Java API
Java API
Iterate over all elements of the buffer map and apply a function to each element.
- f
the function to apply to each element
- def foreach(f: (I, MessageBuffer) => Unit): Unit
Iterate over all elements of the buffer map and apply a function to each element.
Iterate over all elements of the buffer map and apply a function to each element.
- f
the function to apply to each element
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def getOrEmpty(id: I): MessageBuffer
Get the message buffer for an id, or an empty buffer if the id doesn't exist in the map.
Get the message buffer for an id, or an empty buffer if the id doesn't exist in the map.
- id
the id to get the message buffer for
- returns
the message buffer for the given id or an empty buffer if the id doesn't exist
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def isEmpty: Boolean
Check if the buffer map is empty.
Check if the buffer map is empty.
- returns
if the buffer map is empty
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def nonEmpty: Boolean
Check if the buffer map is not empty.
Check if the buffer map is not empty.
- returns
if the buffer map is not empty
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def remove(id: I): Unit
Remove the buffer for an id.
Remove the buffer for an id.
- id
the id to remove the buffer for
- def size: Int
How many ids are in the buffer map.
How many ids are in the buffer map.
- returns
the number of ids in the buffer map
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def totalSize: Int
How many elements are in the buffers in the buffer map.
How many elements are in the buffers in the buffer map.
- returns
the number of elements in the buffers in the buffer map
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- def formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from MessageBufferMap[I] toStringFormat[MessageBufferMap[I]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.12.16) Use
formatString.format(value)instead ofvalue.formatted(formatString), or use thef""string interpolator. In Java 15 and later,formattedresolves to the new method in String which has reversed parameters.
- def →[B](y: B): (MessageBufferMap[I], B)
- Implicit
- This member is added by an implicit conversion from MessageBufferMap[I] toArrowAssoc[MessageBufferMap[I]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use
->instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.