Package io.datareplication.consumer

Class StreamingPage.Chunk.BodyChunk<EntityHeader>

java.lang.Object

io.datareplication.consumer.StreamingPage.Chunk<EntityHeader>

io.datareplication.consumer.StreamingPage.Chunk.BodyChunk<EntityHeader>

Type Parameters:

EntityHeader - the type of the entity headers; see Entity

Enclosing class:

StreamingPage.Chunk<EntityHeader>

public static final class StreamingPage.Chunk.BodyChunk<EntityHeader>
extends StreamingPage.Chunk<EntityHeader>

A block of data of the current entity's body.

May be followed by:

• StreamingPage.Chunk.BodyChunk: further body bytes
• StreamingPage.Chunk.BodyEnd: when the end of the entity's body is reached

Nested Class Summary

Nested classes/interfaces inherited from class io.datareplication.consumer.StreamingPage.Chunk

StreamingPage.Chunk.BodyChunk<EntityHeader>, StreamingPage.Chunk.BodyEnd<EntityHeader>, StreamingPage.Chunk.Header<EntityHeader>

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(java.lang.Object other)
@NonNull java.nio.ByteBuffer	data()	The chunk's byte data.
boolean	equals(java.lang.Object o)
int	hashCode()
java.lang.String	toString()

Methods inherited from class io.datareplication.consumer.StreamingPage.Chunk

bodyChunk, bodyEnd, header

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

data

@NonNull
public @NonNull java.nio.ByteBuffer data()

The chunk's byte data. The ByteBuffer will have its entire capacity used (i.e. Buffer.position() == 0 and == capacity). When returned from StreamingPage, the buffer will not be shared and may be freely modified.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

canEqual

protected boolean canEqual(java.lang.Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object