Package org.infinispan.server.hotrod.streaming

Class GetStreamingState

java.lang.Object

org.infinispan.server.hotrod.streaming.StreamingState

org.infinispan.server.hotrod.streaming.GetStreamingState

public class GetStreamingState
extends StreamingState

Constructor Summary

Constructors

Constructor	Description
GetStreamingState(byte[] key, io.netty.channel.Channel channelUsed, byte[] value, int batchAmount)

Method Summary

Modifier and Type	Method	Description
void	close()
void	closeGet()
boolean	isGetComplete()
io.netty.buffer.ByteBuf	nextGet()

Methods inherited from class org.infinispan.server.hotrod.streaming.StreamingState

closePut, getKey, metadataForPut, nextPut, valueForPut, verifyCorrectThread, versionForPut

Methods inherited from class java.lang.Object

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

Constructor Details

GetStreamingState

public GetStreamingState(byte[] key,
 io.netty.channel.Channel channelUsed,
 byte[] value,
 int batchAmount)

Method Details

nextGet

public io.netty.buffer.ByteBuf nextGet()

Overrides:

nextGet in class StreamingState

isGetComplete

public boolean isGetComplete()

Overrides:

isGetComplete in class StreamingState

closeGet

public void closeGet()

Overrides:

closeGet in class StreamingState

close

public void close()

Specified by:

close in class StreamingState