AckedReceiveBuffer

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

def +(other: String): String

def ->[B](y: B): (AckedReceiveBuffer[T], B)

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

val buf: SortedSet[T]

Buffer of messages that are waiting for delivery

def clone(): AnyRef

val cumulativeAck: SeqNo

The highest sequence number received so far.

def ensuring(cond: (AckedReceiveBuffer[T]) ⇒ Boolean, msg: ⇒ Any): AckedReceiveBuffer[T]

def ensuring(cond: (AckedReceiveBuffer[T]) ⇒ Boolean): AckedReceiveBuffer[T]

def ensuring(cond: Boolean, msg: ⇒ Any): AckedReceiveBuffer[T]

def ensuring(cond: Boolean): AckedReceiveBuffer[T]

final def eq(arg0: AnyRef): Boolean

def extractDeliverable: (AckedReceiveBuffer[T], Seq[T], Ack)

Extract all messages that could be safely delivered, an updated ack to be sent to the sender, and an updated buffer that has the messages removed that can be delivered.

def finalize(): Unit

def formatted(fmtstr: String): String

final def getClass(): Class[_]

final def isInstanceOf[T0]: Boolean

val lastDelivered: SeqNo

Sequence number of the last message that has been delivered.

def mergeFrom(that: AckedReceiveBuffer[T]): AckedReceiveBuffer[T]

Merges two receive buffers.

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def receive(arrivedMsg: T): AckedReceiveBuffer[T]

Puts a sequenced message in the receive buffer returning a new buffer.

implicit val seqOrdering: Ordering[T]

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def →[B](y: B): (AckedReceiveBuffer[T], B)

val self: Any

val self: Any

def x: AckedReceiveBuffer[T]

def x: AckedReceiveBuffer[T]