BoundedBlockingQueue wraps any Queue and turns the result into a BlockingQueue with a limited capacity.
BoundedBlockingQueue wraps any Queue and turns the result into a BlockingQueue with a limited capacity.
- The type of the contents of this Queue
An iterator over a ByteString.
A rope-like immutable data structure containing bytes.
A rope-like immutable data structure containing bytes. The goal of this structure is to reduce copying of arrays when concatenating and slicing sequences of bytes, and also providing a thread safe way of working with bytes.
TODO: Add performance characteristics
A mutable builder for efficiently creating a akka.util.ByteString.
A mutable builder for efficiently creating a akka.util.ByteString.
The created ByteString is not automatically compacted.
ClassLoaderObjectInputStream tries to utilize the provided ClassLoader to load Classes and falls back to ObjectInputStreams resolver.
A compact ByteString.
A compact ByteString.
The ByteString is guarantied to be contiguous in memory and to use only as much memory as required for its contents.
An implementation of a ConcurrentMultiMap Adds/remove is serialized over the specified key Reads are fully concurrent <-- el-cheapo
An implementation of a ConcurrentMultiMap Adds/remove is serialized over the specified key Reads are fully concurrent <-- el-cheapo
Typeclass which describes a classification hierarchy.
Typeclass which describes a classification hierarchy. Observe the contract between isEqual
and isSubclass
!
An atomic switch that can be either on or off
Set of methods which allow easy implementation of hashCode
.
Set of methods which allow easy implementation of hashCode
.
Example:
override def hashCode: Int = { var result = HashCode.SEED //collect the contributions of various fields result = HashCode.hash(result, fPrimitive) result = HashCode.hash(result, fObject) result = HashCode.hash(result, fArray) result }
A Timeout is a wrapper on top of Duration to be more specific about what the duration means.