net.openhft.chronicle.wire

Class InputStreamToWire

java.lang.Object

net.openhft.chronicle.wire.InputStreamToWire

public class InputStreamToWire
extends Object

Provides a bridge to read structured data in Chronicle Wire format from a standard Java InputStream. The stream is expected to contain a sequence of messages, each prefixed with its length as a 4-byte integer. The payload of each message is read into an internal Bytes buffer and presented through a Wire implementation for deserialisation.

The provided InputStream is not closed by this class; callers remain responsible for its lifecycle. This class is useful when Chronicle Wire needs to consume data from sources such as network sockets or files where frames are delimited with explicit length prefixes.

See Also:

Wire, InputStream, DataInputStream

Constructor Summary

Constructors

Constructor and Description
InputStreamToWire(WireType wireType, InputStream is) Creates a new instance configured with the given wire type and input stream.

Method Summary

Modifier and Type	Method and Description
Wire	readOne() Reads the next length-prefixed message from the input stream and makes it available through the internal Wire instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InputStreamToWire

public InputStreamToWire(WireType wireType,
                         InputStream is)

Creates a new instance configured with the given wire type and input stream.

Parameters:

wireType - the WireType used to interpret the message payloads

is - the InputStream from which data will be read.

Method Detail

readOne

public Wire readOne()
             throws IOException

Reads the next length-prefixed message from the input stream and makes it available through the internal Wire instance. The wire and its backing buffer are cleared before reading the 4-byte length header. A negative length results in a StreamCorruptedException. After the bytes are read, the wire is positioned at the start of the message payload.

Returns:

the internal Wire ready for deserialisation; the same instance is reused for each call

Throws:

IOException - if an I/O error occurs

EOFException - if the stream ends unexpectedly

StreamCorruptedException - if a negative length is encountered