BoundedBlockingQueue wraps any Queue and turns the result into a BlockingQueue with a limited capacity
An iterator over a ByteString.
A rope-like immutable data structure containing bytes.
A mutable builder for efficiently creating a akka.util.ByteString.
ClassLoaderObjectInputStream tries to utilize the provided ClassLoader to load Classes and falls back to ObjectInputStreams resolver.
A compact ByteString.
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.
An atomic switch that can be either on or off
Set of methods which allow easy implementation of hashCode
.
A Timeout is a wrapper on top of Duration to be more specific about what the duration means.