net.openhft.chronicle.bytes

Interface StreamingDataInput<S extends StreamingDataInput<S>>

Type Parameters:

S - the concrete type

All Superinterfaces:

RandomCommon, net.openhft.chronicle.core.io.ReferenceCounted, net.openhft.chronicle.core.io.ReferenceOwner, StreamingCommon<S>

All Known Subinterfaces:

Bytes<U>, BytesIn<U>, ByteStringParser<B>

All Known Implementing Classes:

AbstractBytes, GuardedNativeBytes, HexDumpBytes, MappedBytes, NativeBytes, OnHeapBytes, SubBytes, UncheckedBytes, UncheckedNativeBytes, VanillaBytes

public interface StreamingDataInput<S extends StreamingDataInput<S>>
extends StreamingCommon<S>

Provides sequential, cursor based reading of binary and textual data from a stream or buffer. Methods typically advance the RandomCommon.readPosition() by the number of bytes consumed. Implementations may also offer lenient mode in which reads beyond a limit return default values rather than throwing. This interface extends StreamingCommon and ByteStringParser.

Field Summary

Fields inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

INIT, TMP

Method Summary

Modifier and Type	Method and Description
long	copyTo(@NotNull BytesStore<?,?> to) Copies the data from the input stream to the provided BytesStore.
void	copyTo(@NotNull OutputStream out) Copies the data from the input stream to the provided OutputStream.
default @NotNull InputStream	inputStream() Provides an InputStream for the data represented by this StreamingDataInput.
boolean	lenient()
void	lenient(boolean lenient) When there is no more data to read, return zero, false and empty string.
default long	parseHexLong() Parses a hexadecimal long value from the input stream.
default void	parseUtf8(@NotNull Appendable sb, boolean utf, int length) Parses a UTF-8 string from the input stream into the provided Appendable.
default void	parseUtf8(@NotNull Appendable sb, int encodedLength) Parses a UTF-8 string from the input stream into the provided Appendable.
int	peekUnsignedByte() Peeks (reads without moving the read pointer) the next unsigned byte from the input stream.
default byte	rawReadByte() Reads a raw byte value from the input stream.
default int	rawReadInt() Reads a 32-bit integer value from the input stream without performing boundary checks.
default long	rawReadLong() Reads a 64-bit long value from the input stream without performing boundary checks.
default int	read(byte[] bytes) Reads the input stream into the provided byte array.
default int	read(byte[] bytes, int off, int len) Reads the input stream into the provided byte array, starting from the given offset and reading up to the specified length.
default void	read(@NotNull ByteBuffer buffer) Reads the input stream into the provided ByteBuffer.
default void	read(@NotNull Bytes<?> bytes) Transfers as many bytes as possible from the input stream into the provided Bytes object.
default void	read(@NotNull Bytes<?> bytes, int length) Transfers the specified number of bytes from the input stream into the provided Bytes object.
default int	read(char[] bytes, int off, int len) Reads the input stream into the provided char array, starting from the given offset and reading up to the specified length.
default @Nullable String	read8bit() Reads an 8-bit encoded string from the input stream.
default boolean	read8bit(@NotNull Bytes<?> b) Reads an 8-bit encoded string from the input stream and appends it to the provided Bytes.
default boolean	read8bit(@NotNull StringBuilder sb) Reads an 8-bit encoded string from the input stream and appends it to the provided StringBuilder.
default @NotNull BigDecimal	readBigDecimal() Creates and returns a new BigDecimal representing the contents of this Bytes object.
default @NotNull BigInteger	readBigInteger() Creates and returns a new BigInteger representing the contents of this Bytes object or BigInteger.ZERO if this Bytes object is empty.
default boolean	readBoolean() Reads a boolean value from the input stream.
byte	readByte() Reads a byte value from the input stream.
default char	readChar() Reads a character value from the input stream.
double	readDouble() Reads a 64-bit floating-point number from the input stream.
default <E extends Enum<E>> E	readEnum(@NotNull Class<E> eClass) Reads an Enum value from the input stream.
float	readFloat() Reads a 32-bit floating-point number from the input stream.
default void	readHistogram(@NotNull net.openhft.chronicle.core.util.Histogram histogram) Reads data from the input stream into the provided Histogram.
default long	readIncompleteLong()
int	readInt() Reads a 32-bit integer value from the input stream.
default int	readInt24() Reads a 24-bit signed integer value from the input stream.
S	readLimit(long limit) Sets the read limit of this StreamingDataInput.
default S	readLimitToCapacity() Sets the read limit of this StreamingDataInput to its capacity.
long	readLong() Reads a 64-bit long value from the input stream.
S	readPosition(long position) Sets the read position of this StreamingDataInput.
default long	readPositionForHeader(boolean skipPadding) Obtains the current read position, optionally skipping padding bytes if specified.
default S	readPositionRemaining(long position, long remaining) Sets the read position and limit of this StreamingDataInput based on the specified position and remaining values.
default S	readPositionUnlimited(long position) Sets the read position after first widening the read limit to RandomCommon.capacity().
short	readShort() Reads a 16-bit short value from the input stream.
S	readSkip(long bytesToSkip) Advances the read position by bytesToSkip.
default long	readStopBit() Reads a variable-length integer encoded using the stop bit encoding.
default char	readStopBitChar() Reads a variable-length character encoded using the stop bit encoding.
default double	readStopBitDecimal() Reads a decimal number represented as a variable-length double and scale encoded using the stop bit encoding.
default double	readStopBitDouble() Reads a variable-length double encoded using the stop bit encoding.
int	readUnsignedByte() Reads the next unsigned 8-bit value from the input stream.
default long	readUnsignedInt() Reads a 32-bit value from the input stream and converts it to an unsigned integer by masking the sign bit.
default int	readUnsignedInt24() Reads a 24-bit unsigned integer value from the input stream.
default int	readUnsignedShort() Reads a 16-bit value from the input stream and converts it to an unsigned short by masking the sign bit.
default @Nullable String	readUtf8() Reads a UTF-8 encoded string from the input stream.
default boolean	readUtf8(@NotNull Bytes<?> sb) Reads a UTF-8 encoded string from the input stream and appends it to the provided Bytes.
default <C extends Appendable & CharSequence> boolean	readUtf8(C sb) Reads a UTF-8 encoded string from the input stream and appends it to the provided appendable.
default boolean	readUtf8(@NotNull StringBuilder sb) Reads a UTF-8 encoded string from the input stream and appends it to the provided StringBuilder.
int	readVolatileInt() Reads a volatile (concurrently mutable) integer value from the input stream.
long	readVolatileLong() Reads a volatile (concurrently mutable) long value from the input stream.
default void	readWithLength(@NotNull Bytes<?> bytes) Reads data from the input stream with specified length into the provided Bytes.
default void	readWithLength(long length, @NotNull net.openhft.chronicle.core.util.ThrowingConsumer<S,net.openhft.chronicle.core.io.IORuntimeException> bytesConsumer) Same as readWithLength0(long, ThrowingConsumerNonCapturing, StringBuilder, BytesOut) but without the extra StringBuilder and BytesOut parameters.
default void	readWithLength0(long length, @NotNull net.openhft.chronicle.core.util.ThrowingConsumerNonCapturing<S,net.openhft.chronicle.core.io.IORuntimeException,BytesOut> bytesConsumer, StringBuilder sb, BytesOut<?> toBytes) Temporarily restricts the RandomCommon.readLimit() to readPosition() + length, invokes bytesConsumer, then restores the original limit and advances the read position by length.
void	uncheckedReadSkipBackOne() Unchecked version of readSkip(-1).
void	uncheckedReadSkipOne() Unchecked version of readSkip(1).
int	uncheckedReadUnsignedByte() Reads the next unsigned 8-bit value from the input stream without performing boundary checks.
default S	unsafeRead(long address, int length) Reads data from the input stream into the memory at the provided address.
default void	unsafeReadObject(@NotNull Object o, int offset, int length) Reads data from the input stream into the provided object, starting from the given offset.

Methods inherited from interface net.openhft.chronicle.bytes.StreamingCommon

clear

Methods inherited from interface net.openhft.chronicle.bytes.RandomCommon

addressForRead, addressForRead, addressForWrite, addressForWritePosition, byteOrder, bytesForRead, bytesForWrite, capacity, isDirectMemory, lengthWritten, readLimit, readPosition, readRemaining, realCapacity, realReadRemaining, realWriteRemaining, sharedMemory, start, writeLimit, writePosition, writeRemaining

Methods inherited from interface net.openhft.chronicle.core.io.ReferenceCounted

addReferenceChangeListener, refCount, release, releaseLast, releaseLast, removeReferenceChangeListener, reserve, reserveTransfer, tryReserve

Methods inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

referenceId, referenceName, temporary

Method Detail

readPosition

@NotNull
S readPosition(long position)
                 throws BufferUnderflowException,
                        IllegalStateException,
                        net.openhft.chronicle.core.io.ClosedIllegalStateException,
                        net.openhft.chronicle.core.io.ThreadingIllegalStateException

Sets the read position of this StreamingDataInput.

Parameters:

position - the new read position, must be non-negative

Returns:

this StreamingDataInput instance, for chaining

Throws:

BufferUnderflowException - If the new position is greater than the limit

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

IllegalStateException

readPositionUnlimited

@NotNull
default S readPositionUnlimited(long position)
                                  throws BufferUnderflowException,
                                         net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                         net.openhft.chronicle.core.io.ThreadingIllegalStateException

Sets the read position after first widening the read limit to RandomCommon.capacity(). Useful when random access is required regardless of the current limit.

Parameters:

position - the new read position

Returns:

this instance for chaining

Throws:

BufferUnderflowException - if the position is beyond the capacity

net.openhft.chronicle.core.io.ClosedIllegalStateException - if the resource has been released or closed

net.openhft.chronicle.core.io.ThreadingIllegalStateException - if accessed by multiple threads in an unsafe way

readPositionRemaining

@NotNull
default S readPositionRemaining(long position,
                                         long remaining)
                                  throws BufferUnderflowException,
                                         net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                         net.openhft.chronicle.core.io.ThreadingIllegalStateException

Sets the read position and limit of this StreamingDataInput based on the specified position and remaining values.

Parameters:

position - the new read position, must be non-negative

remaining - the remaining size, which is used to set the read limit

Returns:

this StreamingDataInput instance, for chaining

Throws:

BufferUnderflowException - If the new position is greater than the read limit

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readLimit

@NotNull
S readLimit(long limit)
              throws BufferUnderflowException,
                     net.openhft.chronicle.core.io.ThreadingIllegalStateException

Sets the read limit of this StreamingDataInput.

Parameters:

limit - the new read limit, must be non-negative

Returns:

this StreamingDataInput instance, for chaining

Throws:

BufferUnderflowException - If the new limit is less than the read position

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readLimitToCapacity

default S readLimitToCapacity()
                       throws BufferUnderflowException,
                              net.openhft.chronicle.core.io.ThreadingIllegalStateException

Sets the read limit of this StreamingDataInput to its capacity.

Returns:

this StreamingDataInput instance, for chaining

Throws:

BufferUnderflowException - If the capacity is less than the read position

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readSkip

@NotNull
S readSkip(long bytesToSkip)
             throws BufferUnderflowException,
                    IllegalStateException,
                    net.openhft.chronicle.core.io.ClosedIllegalStateException,
                    net.openhft.chronicle.core.io.ThreadingIllegalStateException

Advances the read position by bytesToSkip. If lenient mode is active, attempts to move beyond the read limit are capped at the limit without throwing.

Parameters:

bytesToSkip - the number of bytes to skip

Returns:

this instance for chaining

Throws:

BufferUnderflowException - if the new position exceeds the limit and lenient mode is off

net.openhft.chronicle.core.io.ClosedIllegalStateException - if the resource has been released or closed

net.openhft.chronicle.core.io.ThreadingIllegalStateException - if accessed by multiple threads in an unsafe way

IllegalStateException

readPositionForHeader

default long readPositionForHeader(boolean skipPadding)
                            throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                   net.openhft.chronicle.core.io.ThreadingIllegalStateException

Obtains the current read position, optionally skipping padding bytes if specified. Useful when reading data with headers that may include padding.

Parameters:

skipPadding - if true, aligns the read position to a 4-byte boundary by skipping padding bytes

Returns:

the current read position

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

uncheckedReadSkipOne

void uncheckedReadSkipOne()

Unchecked version of readSkip(1). This method skips one byte without performing any limit checks. Use this method only when you are certain that it is safe to do so, and you have identified a performance issue with readSkip(1).

uncheckedReadSkipBackOne

void uncheckedReadSkipBackOne()

Unchecked version of readSkip(-1). This method skips back one byte without performing any limit checks. Use this method only when you are certain that it is safe to do so, and you have identified a performance issue with readSkip(-1).

readWithLength0

default void readWithLength0(long length,
                             @NotNull
                             @NotNull net.openhft.chronicle.core.util.ThrowingConsumerNonCapturing<S,net.openhft.chronicle.core.io.IORuntimeException,BytesOut> bytesConsumer,
                             StringBuilder sb,
                             BytesOut<?> toBytes)
                      throws BufferUnderflowException,
                             net.openhft.chronicle.core.io.IORuntimeException,
                             net.openhft.chronicle.core.io.ClosedIllegalStateException,
                             net.openhft.chronicle.core.io.ThreadingIllegalStateException

Temporarily restricts the RandomCommon.readLimit() to readPosition() + length, invokes bytesConsumer, then restores the original limit and advances the read position by length. Intended for processing length prefixed sections.

Parameters:

length - the temporary length

bytesConsumer - action to perform within the bounds

sb - optional string builder used by some consumers

toBytes - optional buffer used by some consumers

Throws:

BufferUnderflowException - if the length exceeds the remaining bytes

net.openhft.chronicle.core.io.IORuntimeException - if the consumer throws an I/O error

net.openhft.chronicle.core.io.ClosedIllegalStateException - if the resource has been released or closed

net.openhft.chronicle.core.io.ThreadingIllegalStateException - if accessed by multiple threads in an unsafe way

readWithLength

default void readWithLength(long length,
                            @NotNull
                            @NotNull net.openhft.chronicle.core.util.ThrowingConsumer<S,net.openhft.chronicle.core.io.IORuntimeException> bytesConsumer)
                     throws BufferUnderflowException,
                            net.openhft.chronicle.core.io.IORuntimeException,
                            net.openhft.chronicle.core.io.ClosedIllegalStateException,
                            net.openhft.chronicle.core.io.ThreadingIllegalStateException

Same as readWithLength0(long, ThrowingConsumerNonCapturing, StringBuilder, BytesOut) but without the extra StringBuilder and BytesOut parameters.

Parameters:

length - the temporary length

bytesConsumer - action to perform within the bounds

Throws:

BufferUnderflowException - if the length exceeds the remaining bytes

net.openhft.chronicle.core.io.IORuntimeException - if the consumer throws an I/O error

net.openhft.chronicle.core.io.ClosedIllegalStateException - if the resource has been released or closed

net.openhft.chronicle.core.io.ThreadingIllegalStateException - if accessed by multiple threads in an unsafe way

inputStream

@NotNull
default @NotNull InputStream inputStream()

Provides an InputStream for the data represented by this StreamingDataInput.

Returns:

an InputStream over the underlying data

readStopBit

default long readStopBit()
                  throws net.openhft.chronicle.core.io.IORuntimeException,
                         net.openhft.chronicle.core.io.ClosedIllegalStateException,
                         BufferUnderflowException

Reads a variable-length integer encoded using the stop bit encoding. This method is equivalent to calling BytesInternal.readStopBit(this).

Returns:

the decoded integer

Throws:

net.openhft.chronicle.core.io.IORuntimeException - If an I/O error occurs

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readStopBitChar

default char readStopBitChar()
                      throws net.openhft.chronicle.core.io.IORuntimeException,
                             net.openhft.chronicle.core.io.ClosedIllegalStateException,
                             BufferUnderflowException

Reads a variable-length character encoded using the stop bit encoding. This method is equivalent to calling BytesInternal.readStopBitChar(this).

Returns:

the decoded character

Throws:

net.openhft.chronicle.core.io.IORuntimeException - If an I/O error occurs

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readStopBitDouble

default double readStopBitDouble()
                          throws net.openhft.chronicle.core.io.ClosedIllegalStateException

Reads a variable-length double encoded using the stop bit encoding. This method is equivalent to calling BytesInternal.readStopBitDouble(this).

Returns:

the decoded double

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readStopBitDecimal

default double readStopBitDecimal()
                           throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                  BufferUnderflowException

Reads a decimal number represented as a variable-length double and scale encoded using the stop bit encoding. The absolute value of the returned double represents the value of the decimal, and the sign represents the sign of the decimal.

Returns:

the decoded decimal number

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readBoolean

default boolean readBoolean()
                     throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                            net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a boolean value from the input stream. It reads a byte and converts it into a boolean using BytesUtil.byteToBoolean(b).

Returns:

the boolean value

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readByte

byte readByte()
       throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
              net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a byte value from the input stream.

Returns:

the byte value

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

rawReadByte

default byte rawReadByte()
                  throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                         net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a raw byte value from the input stream. The main difference between this method and readByte() is that the latter might perform additional processing or checks.

Returns:

the raw byte value

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readChar

default char readChar()
               throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                      BufferUnderflowException

Reads a character value from the input stream. The character is read using the stop bit encoding.

Returns:

the character value

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

BufferUnderflowException - If there's not enough data to read

readUnsignedByte

int readUnsignedByte()
              throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                     net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads the next unsigned 8-bit value from the input stream. If there is no byte available, it returns -1.

Returns:

the next unsigned 8-bit value or -1

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

uncheckedReadUnsignedByte

int uncheckedReadUnsignedByte()

Reads the next unsigned 8-bit value from the input stream without performing boundary checks. If there is no byte available, it returns -1. Use this method with caution as it bypasses checks for data availability.

Returns:

the next unsigned 8-bit value or -1

readShort

short readShort()
         throws BufferUnderflowException,
                IllegalStateException,
                net.openhft.chronicle.core.io.ClosedIllegalStateException,
                net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 16-bit short value from the input stream.

Returns:

the 16-bit short value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

IllegalStateException

readUnsignedShort

default int readUnsignedShort()
                       throws BufferUnderflowException,
                              net.openhft.chronicle.core.io.ClosedIllegalStateException,
                              net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 16-bit value from the input stream and converts it to an unsigned short by masking the sign bit.

Returns:

the unsigned 16-bit value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readInt24

default int readInt24()
               throws BufferUnderflowException,
                      net.openhft.chronicle.core.io.ClosedIllegalStateException,
                      net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 24-bit signed integer value from the input stream. This is achieved by reading an unsigned short and an unsigned byte, and then bit-shifting and combining them to form a 24-bit integer.

Returns:

the 24-bit integer value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readUnsignedInt24

default int readUnsignedInt24()
                       throws BufferUnderflowException,
                              net.openhft.chronicle.core.io.ClosedIllegalStateException,
                              net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 24-bit unsigned integer value from the input stream. This is achieved by reading an unsigned short and an unsigned byte, and then bit-shifting and combining them to form a 24-bit unsigned integer.

Returns:

the 24-bit unsigned integer value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readInt

int readInt()
     throws BufferUnderflowException,
            net.openhft.chronicle.core.io.ClosedIllegalStateException,
            net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 32-bit integer value from the input stream.

Returns:

the 32-bit integer value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

rawReadInt

default int rawReadInt()
                throws BufferUnderflowException,
                       net.openhft.chronicle.core.io.ClosedIllegalStateException,
                       net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 32-bit integer value from the input stream without performing boundary checks. Use this method with caution as it bypasses checks for data availability.

Returns:

the 32-bit integer value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readUnsignedInt

default long readUnsignedInt()
                      throws BufferUnderflowException,
                             net.openhft.chronicle.core.io.ClosedIllegalStateException,
                             net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 32-bit value from the input stream and converts it to an unsigned integer by masking the sign bit.

Returns:

the unsigned 32-bit integer value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readLong

long readLong()
       throws BufferUnderflowException,
              net.openhft.chronicle.core.io.ClosedIllegalStateException,
              net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 64-bit long value from the input stream.

Returns:

the 64-bit long value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

rawReadLong

default long rawReadLong()
                  throws BufferUnderflowException,
                         IllegalStateException,
                         net.openhft.chronicle.core.io.ClosedIllegalStateException,
                         net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 64-bit long value from the input stream without performing boundary checks. Use this method with caution as it bypasses checks for data availability.

Returns:

the 64-bit long value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

IllegalStateException

readIncompleteLong

default long readIncompleteLong()
                         throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                net.openhft.chronicle.core.io.ThreadingIllegalStateException

Returns:

a long using the bytes remaining

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readFloat

float readFloat()
         throws BufferUnderflowException,
                net.openhft.chronicle.core.io.ClosedIllegalStateException,
                net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 32-bit floating-point number from the input stream.

Returns:

the float value read from the stream

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readDouble

double readDouble()
           throws BufferUnderflowException,
                  net.openhft.chronicle.core.io.ClosedIllegalStateException,
                  net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a 64-bit floating-point number from the input stream.

Returns:

the double value read from the stream

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readUtf8

@Nullable
default @Nullable String readUtf8()
                                     throws BufferUnderflowException,
                                            net.openhft.chronicle.core.io.IORuntimeException,
                                            net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                            ArithmeticException

Reads a UTF-8 encoded string from the input stream. This method supports null values and utilizes stop bit encoding for length, saving one byte for strings shorter than 128 characters.

Returns:

a Unicode string or null if writeUtf8(null) was called

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.IORuntimeException - If an IO error occurs

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

ArithmeticException - If numeric overflow or underflow occurs

read8bit

@Nullable
default @Nullable String read8bit()
                                     throws net.openhft.chronicle.core.io.IORuntimeException,
                                            BufferUnderflowException,
                                            net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                            ArithmeticException

Reads an 8-bit encoded string from the input stream.

Returns:

an 8-bit string or null if write8bit(null) was called

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.IORuntimeException - If an IO error occurs

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

ArithmeticException - If numeric overflow or underflow occurs

readUtf8

default <C extends Appendable & CharSequence> boolean readUtf8(@NotNull
                                                               C sb)
                                                        throws net.openhft.chronicle.core.io.IORuntimeException,
                                                               BufferUnderflowException,
                                                               ArithmeticException,
                                                               net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                                               IllegalArgumentException

Reads a UTF-8 encoded string from the input stream and appends it to the provided appendable. This method is similar to readUtf8(), except it populates a provided appendable instead of creating a new string.

Parameters:

sb - the appendable to which the read string will be appended

Returns:

true if there was a String, or false if it was null

Throws:

net.openhft.chronicle.core.io.IORuntimeException - If an IO error occurs

BufferUnderflowException - If there's not enough data to read

ArithmeticException - If numeric overflow or underflow occurs

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

IllegalArgumentException - If the appendable does not allow setting length

readUtf8

default boolean readUtf8(@NotNull
                         @NotNull Bytes<?> sb)
                  throws net.openhft.chronicle.core.io.IORuntimeException,
                         BufferUnderflowException,
                         ArithmeticException,
                         net.openhft.chronicle.core.io.ClosedIllegalStateException,
                         net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a UTF-8 encoded string from the input stream and appends it to the provided Bytes. This method is similar to readUtf8(), except it populates a provided Bytes instance instead of creating a new string.

Parameters:

sb - the Bytes instance to which the read string will be appended

Returns:

true if there was a String, or false if it was null

Throws:

net.openhft.chronicle.core.io.IORuntimeException - If an IO error occurs

BufferUnderflowException - If there's not enough data to read

ArithmeticException - If numeric overflow or underflow occurs

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readUtf8

default boolean readUtf8(@NotNull
                         @NotNull StringBuilder sb)
                  throws net.openhft.chronicle.core.io.IORuntimeException,
                         BufferUnderflowException,
                         ArithmeticException,
                         net.openhft.chronicle.core.io.ClosedIllegalStateException

Reads a UTF-8 encoded string from the input stream and appends it to the provided StringBuilder. This method is similar to readUtf8(), except it populates a provided StringBuilder instead of creating a new string.

Parameters:

sb - the StringBuilder to which the read string will be appended

Returns:

true if there was a String, or false if it was null

Throws:

net.openhft.chronicle.core.io.IORuntimeException - If an IO error occurs

BufferUnderflowException - If there's not enough data to read

ArithmeticException - If numeric overflow or underflow occurs

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

read8bit

default boolean read8bit(@NotNull
                         @NotNull Bytes<?> b)
                  throws BufferUnderflowException,
                         net.openhft.chronicle.core.io.ClosedIllegalStateException,
                         ArithmeticException,
                         BufferOverflowException,
                         net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads an 8-bit encoded string from the input stream and appends it to the provided Bytes.

Parameters:

b - the Bytes instance to which the read string will be appended

Returns:

true if there was a String, or false if it was null

Throws:

BufferUnderflowException - If there's not enough data to read

ArithmeticException - If numeric overflow or underflow occurs

BufferOverflowException - If the buffer is full

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

read8bit

default boolean read8bit(@NotNull
                         @NotNull StringBuilder sb)
                  throws net.openhft.chronicle.core.io.IORuntimeException,
                         BufferUnderflowException,
                         ArithmeticException,
                         net.openhft.chronicle.core.io.ClosedIllegalStateException

Reads an 8-bit encoded string from the input stream and appends it to the provided StringBuilder.

Parameters:

sb - the StringBuilder to which the read string will be appended

Returns:

true if there was a String, or false if it was null

Throws:

net.openhft.chronicle.core.io.IORuntimeException - If an IO error occurs

BufferUnderflowException - If there's not enough data to read

ArithmeticException - If numeric overflow or underflow occurs

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

read

default int read(byte[] bytes)
          throws BufferUnderflowException,
                 IllegalStateException,
                 net.openhft.chronicle.core.io.ClosedIllegalStateException,
                 net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads the input stream into the provided byte array.

Parameters:

bytes - the byte array to fill with the read data

Returns:

the number of bytes read, or -1 if the end of the stream is reached

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

IllegalStateException

read

default int read(byte[] bytes,
                 int off,
                 int len)
          throws BufferUnderflowException,
                 net.openhft.chronicle.core.io.ClosedIllegalStateException,
                 net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads the input stream into the provided byte array, starting from the given offset and reading up to the specified length.

Parameters:

bytes - the byte array to fill with the read data

off - the start offset in the byte array

len - the maximum number of bytes to read

Returns:

the number of bytes read, or -1 if the end of the stream is reached

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

read

default int read(char[] bytes,
                 int off,
                 int len)
          throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                 net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads the input stream into the provided char array, starting from the given offset and reading up to the specified length.

Parameters:

bytes - the char array to fill with the read data

off - the start offset in the char array

len - the maximum number of chars to read

Returns:

the number of chars read, or -1 if the end of the stream is reached

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

read

default void read(@NotNull
                  @NotNull ByteBuffer buffer)
           throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                  net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads the input stream into the provided ByteBuffer.

Parameters:

buffer - the ByteBuffer to fill with the read data

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

read

default void read(@NotNull
                  @NotNull Bytes<?> bytes)
           throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                  net.openhft.chronicle.core.io.ThreadingIllegalStateException

Transfers as many bytes as possible from the input stream into the provided Bytes object.

Parameters:

bytes - the Bytes object to fill with the read data

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

See Also:

StreamingDataOutput.write(BytesStore)

read

default void read(@NotNull
                  @NotNull Bytes<?> bytes,
                  int length)
           throws BufferUnderflowException,
                  BufferOverflowException,
                  net.openhft.chronicle.core.io.ClosedIllegalStateException,
                  net.openhft.chronicle.core.io.ThreadingIllegalStateException

Transfers the specified number of bytes from the input stream into the provided Bytes object.

Parameters:

bytes - the Bytes object to fill with the read data

length - the number of bytes to read

Throws:

BufferUnderflowException - If there's not enough data to read

BufferOverflowException - If there's not enough space in the provided Bytes object

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

unsafeReadObject

default void unsafeReadObject(@NotNull
                              @NotNull Object o,
                              int offset,
                              int length)
                       throws BufferUnderflowException,
                              net.openhft.chronicle.core.io.ClosedIllegalStateException,
                              net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads data from the input stream into the provided object, starting from the given offset.

Parameters:

o - the object to fill with the read data

offset - the start offset in the object

length - the number of bytes to read

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

unsafeRead

default S unsafeRead(long address,
                     int length)
              throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                     net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads data from the input stream into the memory at the provided address.

Parameters:

address - the address of the memory to fill with the read data

length - the number of bytes to read

Returns:

a reference to this object

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readVolatileInt

int readVolatileInt()
             throws BufferUnderflowException,
                    net.openhft.chronicle.core.io.ClosedIllegalStateException,
                    net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a volatile (concurrently mutable) integer value from the input stream.

Returns:

the read integer value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readVolatileLong

long readVolatileLong()
               throws BufferUnderflowException,
                      net.openhft.chronicle.core.io.ClosedIllegalStateException,
                      net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a volatile (concurrently mutable) long value from the input stream.

Returns:

the read long value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

peekUnsignedByte

int peekUnsignedByte()
              throws net.openhft.chronicle.core.io.ClosedIllegalStateException,
                     net.openhft.chronicle.core.io.ThreadingIllegalStateException

Peeks (reads without moving the read pointer) the next unsigned byte from the input stream.

Returns:

the peeked byte value

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readEnum

@NotNull
default <E extends Enum<E>> E readEnum(@NotNull
                                                @NotNull Class<E> eClass)
                                         throws net.openhft.chronicle.core.io.IORuntimeException,
                                                BufferUnderflowException,
                                                ArithmeticException,
                                                net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                                BufferOverflowException

Reads an Enum value from the input stream.

Parameters:

eClass - the class of the Enum

Returns:

the read Enum value

Throws:

net.openhft.chronicle.core.io.IORuntimeException - If an I/O error occurs

BufferUnderflowException - If there's not enough data to read

ArithmeticException - If the number format is invalid

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

BufferOverflowException - If there's not enough space in the buffer

parseUtf8

default void parseUtf8(@NotNull
                       @NotNull Appendable sb,
                       int encodedLength)
                throws IllegalArgumentException,
                       BufferUnderflowException,
                       UTFDataFormatRuntimeException,
                       net.openhft.chronicle.core.io.ClosedIllegalStateException

Parses a UTF-8 string from the input stream into the provided Appendable.

Parameters:

sb - the Appendable to fill with the parsed string

encodedLength - the length of the UTF-8 encoded data in bytes

Throws:

IllegalArgumentException - If an illegal argument is provided

BufferUnderflowException - If there's not enough data to read

UTFDataFormatRuntimeException - If the string is not valid UTF-8

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

parseUtf8

default void parseUtf8(@NotNull
                       @NotNull Appendable sb,
                       boolean utf,
                       int length)
                throws IllegalArgumentException,
                       BufferUnderflowException,
                       UTFDataFormatRuntimeException,
                       net.openhft.chronicle.core.io.ClosedIllegalStateException

Parses a UTF-8 string from the input stream into the provided Appendable.

Parameters:

sb - the Appendable to fill with the parsed string

utf - true if the length is the UTF-8 encoded length, false if the length is the length of chars

length - the maximum number of bytes to read

Throws:

IllegalArgumentException - If an illegal argument is provided

BufferUnderflowException - If there's not enough data to read

UTFDataFormatRuntimeException - If the string is not valid UTF-8

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

parseHexLong

default long parseHexLong()
                   throws BufferUnderflowException,
                          net.openhft.chronicle.core.io.ClosedIllegalStateException

Parses a hexadecimal long value from the input stream.

Returns:

the parsed long value

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

copyTo

void copyTo(@NotNull
            @NotNull OutputStream out)
     throws IOException,
            net.openhft.chronicle.core.io.ClosedIllegalStateException

Copies the data from the input stream to the provided OutputStream.

Parameters:

out - the OutputStream to copy the data to

Throws:

IOException - If an I/O error occurs

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

copyTo

long copyTo(@NotNull
            @NotNull BytesStore<?,?> to)
     throws net.openhft.chronicle.core.io.ClosedIllegalStateException

Copies the data from the input stream to the provided BytesStore.

Parameters:

to - the BytesStore to copy the data to

Returns:

the number of bytes copied

Throws:

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

readHistogram

default void readHistogram(@NotNull
                           @NotNull net.openhft.chronicle.core.util.Histogram histogram)
                    throws BufferUnderflowException,
                           IllegalStateException,
                           ArithmeticException,
                           net.openhft.chronicle.core.io.ClosedIllegalStateException

Reads data from the input stream into the provided Histogram.

Parameters:

histogram - the Histogram to fill with data

Throws:

BufferUnderflowException - If there's not enough data to read

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

ArithmeticException - If the number format is invalid

IllegalStateException

readWithLength

default void readWithLength(@NotNull
                            @NotNull Bytes<?> bytes)
                     throws ArithmeticException,
                            BufferUnderflowException,
                            BufferOverflowException,
                            net.openhft.chronicle.core.io.ClosedIllegalStateException,
                            net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads data from the input stream with specified length into the provided Bytes.

Parameters:

bytes - the Bytes to fill with data

Throws:

ArithmeticException - If the number format is invalid

BufferUnderflowException - If there's not enough data to read

BufferOverflowException - If there's not enough space in the buffer

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

lenient

void lenient(boolean lenient)

When there is no more data to read, return zero, false and empty string.

Parameters:

lenient - if true, return nothing rather than error.

lenient

boolean lenient()

readBigDecimal

@NotNull
default @NotNull BigDecimal readBigDecimal()
                                             throws ArithmeticException,
                                                    BufferUnderflowException,
                                                    IllegalStateException,
                                                    net.openhft.chronicle.core.io.ClosedIllegalStateException

Creates and returns a new BigDecimal representing the contents of this Bytes object.

If this Byte object is empty, an object equal to BigDecimal.ZERO is returned.

Returns:

a new BigDecimal

Throws:

ArithmeticException - If the content of this Bytes object could not be successfully converted

BufferUnderflowException - If the content of this Bytes object is insufficient to be successfully converted

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way

IllegalStateException

readBigInteger

@NotNull
default @NotNull BigInteger readBigInteger()
                                             throws ArithmeticException,
                                                    BufferUnderflowException,
                                                    net.openhft.chronicle.core.io.ClosedIllegalStateException

Creates and returns a new BigInteger representing the contents of this Bytes object or BigInteger.ZERO if this Bytes object is empty.

Returns:

a new BigInteger

Throws:

ArithmeticException - If the content of this Bytes object could not be successfully converted

BufferUnderflowException - If the content of this Bytes object is insufficient to be successfully converted

net.openhft.chronicle.core.io.ClosedIllegalStateException - If the resource has been released or closed.

net.openhft.chronicle.core.io.ThreadingIllegalStateException - If this resource was accessed by multiple threads in an unsafe way