Package org.apache.pekko.util
package org.apache.pekko.util
-
ClassDescriptionBoundedBlockingQueue 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.An unfragmented ByteString.INTERNAL API: ByteString backed by exactly one array, with start / end markersA compact (unsliced) and unfragmented ByteString, implementation of ByteString1C.A ByteString with 2 or more fragments.A mutable builder for efficiently creating a
ByteString.ClassLoaderObjectInputStream tries to utilize the provided ClassLoader to load Classes and falls back to ObjectInputStreams resolver.INTERNAL APIINTERNAL APIA compact ByteString.ConcurrentMultiMap<K,V> An implementation of a ConcurrentMultiMap Adds/remove is serialized over the specified key Reads are fully concurrent <-- el-cheapoINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APISet of methods which allow easy implementation ofhashCode.Set of methods which allow easy implementation ofhashCode.Implicit class providingrequiringmethods.INTERNAL APIIndex<K,V> An implementation of a ConcurrentMultiMap Adds/remove is serialized over the specified key Reads are fully concurrent <-- el-cheapoINTERNAL APIINTERNAL APIThis is a minimized byte-code parser that concentrates exclusively on line numbers and source file extraction.This is a minimized byte-code parser that concentrates exclusively on line numbers and source file extraction.Utility that extractsManifestInfo#Versioninformation from META-INF/MANIFEST.MF in jar files on the classpath.Comparable version informationApache Pekko extension that extractsManifestInfo.Versioninformation from META-INF/MANIFEST.MF in jar files on the classpath of theClassLoaderof theActorSystem.A non thread safe mutable message buffer that can be used to buffer messages inside actors.A non thread safe mutable message buffer map that can be used to buffer messages inside actors.Default implementation ofTokenBucketthat usesSystem.nanoTimeas the time source.INTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIPriorityQueueStabilizer wraps a priority queue so that it respects FIFO for elements of equal priority.INTERNAL APICollection of internal reflection utilities which may or may not be available (most services specific to HotSpot, but fails gracefully).Collection of internal reflection utilities which may or may not be available (most services specific to HotSpot, but fails gracefully).INTERNAL APIStablePriorityBlockingQueue is a blocking priority queue that preserves order for elements of equal priority.StablePriorityQueue is a priority queue that preserves order for elements of equal priority.Typeclass which describes a classification hierarchy.SWAR (SIMD Within A Register) utility class.SWAR (SIMD Within A Register) utility class.An atomic switch that can be either on or offA Timeout is a wrapper on top of Duration to be more specific about what the duration means.TypedMultiMap<T,K> An immutable multi-map that expresses the value type as a type function of the key type.INTERNAL APIScala implementation of UUIDComparator in https://github.com/cowtowncoder/java-uuid-generator Apache License 2.0.Comparable version information.A time source.