net.openhft.chronicle.bytes

Interface BytesIn<U>

Type Parameters:

U - underlying buffer type

All Superinterfaces:

ByteStringParser<Bytes<U>>, RandomCommon, RandomDataInput, net.openhft.chronicle.core.io.ReferenceCounted, net.openhft.chronicle.core.io.ReferenceOwner, StreamingCommon<Bytes<U>>, StreamingDataInput<Bytes<U>>

All Known Subinterfaces:

Bytes<U>

All Known Implementing Classes:

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

public interface BytesIn<U>
extends RandomDataInput, StreamingDataInput<Bytes<U>>, ByteStringParser<Bytes<U>>

Reads data from a byte stream or buffer. Combines random access, sequential streaming, and text parsing capabilities.

Field Summary

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

INIT, TMP

Method Summary

Modifier and Type	Method and Description
default @NotNull MethodReader	bytesMethodReader(Object... objects) Creates a MethodReader that decodes method calls from this input and dispatches them to the supplied handler objects.
default @NotNull BytesMethodReaderBuilder	bytesMethodReaderBuilder() Creates a builder for the MethodReader.
<T extends ReadBytesMarshallable> T	readMarshallableLength16(@NotNull Class<T> tClass, T using) Reads a ReadBytesMarshallable prefixed with a 16-bit length.
default <T> T	readObject(@NotNull Class<T> componentType0) Reads a simple object such as String, Long or an implementation of BytesMarshallable.

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

canReadDirect, canReadDirect, compareUtf8, copyTo, copyTo, fastHash, findByte, nativeRead, parseLong, peekUnsignedByte, peekVolatileInt, printable, read, readBoolean, readByte, readDouble, readFloat, readIncompleteLong, readInt, readLong, readShort, readUnsignedByte, readUnsignedInt, readUnsignedInt24, readUnsignedShort, readUtf8, readUtf8Limited, readUtf8Limited, readVolatileByte, readVolatileDouble, readVolatileFloat, readVolatileInt, readVolatileLong, readVolatileShort, realCapacity, subBytes, toByteArray, toTemporaryDirectByteBuffer

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

lastDecimalPlaces, lastDecimalPlaces, lastNumberHadDigits, lastNumberHadDigits, parse8bit, parse8bit, parse8bit, parse8bit, parse8bit, parseBigDecimal, parseBoolean, parseBoolean, parseDouble, parseFlexibleLong, parseFloat, parseInt, parseLong, parseLongDecimal, parseUtf8, parseUtf8, parseUtf8, reader, skipTo

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

copyTo, copyTo, inputStream, lenient, lenient, parseHexLong, parseUtf8, parseUtf8, peekUnsignedByte, rawReadByte, rawReadInt, rawReadLong, read, read, read, read, read, read, read8bit, read8bit, read8bit, readBigDecimal, readBigInteger, readBoolean, readByte, readChar, readDouble, readEnum, readFloat, readHistogram, readIncompleteLong, readInt, readInt24, readLimit, readLimitToCapacity, readLong, readPosition, readPositionForHeader, readPositionRemaining, readPositionUnlimited, readShort, readSkip, readStopBit, readStopBitChar, readStopBitDecimal, readStopBitDouble, readUnsignedByte, readUnsignedInt, readUnsignedInt24, readUnsignedShort, readUtf8, readUtf8, readUtf8, readUtf8, readVolatileInt, readVolatileLong, readWithLength, readWithLength, readWithLength0, uncheckedReadSkipBackOne, uncheckedReadSkipOne, uncheckedReadUnsignedByte, unsafeRead, unsafeReadObject

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, 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

bytesMethodReader

@NotNull
default @NotNull MethodReader bytesMethodReader(@NotNull
                                                         Object... objects)

Creates a MethodReader that decodes method calls from this input and dispatches them to the supplied handler objects.

Parameters:

objects - handler instances implementing the expected interfaces

Returns:

a reader that processes one message per invocation of MethodReader.readOne()

bytesMethodReaderBuilder

@NotNull
default @NotNull BytesMethodReaderBuilder bytesMethodReaderBuilder()

Creates a builder for the MethodReader.

Returns:

a BytesMethodReaderBuilder for this BytesIn.

readMarshallableLength16

<T extends ReadBytesMarshallable> T readMarshallableLength16(@NotNull
                                                             @NotNull Class<T> tClass,
                                                             @Nullable
                                                             T using)
                                                      throws BufferUnderflowException,
                                                             net.openhft.chronicle.core.io.InvalidMarshallableException,
                                                             net.openhft.chronicle.core.io.ClosedIllegalStateException,
                                                             net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a ReadBytesMarshallable prefixed with a 16-bit length.

Parameters:

tClass - type of object to create when using is null

using - optional instance to reuse

Returns:

the populated instance

Throws:

BufferUnderflowException

net.openhft.chronicle.core.io.InvalidMarshallableException

net.openhft.chronicle.core.io.ClosedIllegalStateException

net.openhft.chronicle.core.io.ThreadingIllegalStateException

readObject

default <T> T readObject(@NotNull
                         @NotNull Class<T> componentType0)
                  throws BufferUnderflowException,
                         ArithmeticException,
                         BufferOverflowException,
                         net.openhft.chronicle.core.io.InvalidMarshallableException,
                         net.openhft.chronicle.core.io.ClosedIllegalStateException,
                         net.openhft.chronicle.core.io.ThreadingIllegalStateException

Reads a simple object such as String, Long or an implementation of BytesMarshallable.

Parameters:

componentType0 - expected result type

Returns:

the deserialised object

Throws:

UnsupportedOperationException - if componentType0 is not supported

BufferUnderflowException

ArithmeticException

BufferOverflowException

net.openhft.chronicle.core.io.InvalidMarshallableException

net.openhft.chronicle.core.io.ClosedIllegalStateException

net.openhft.chronicle.core.io.ThreadingIllegalStateException