Package org.infinispan.server.hotrod.streaming

Class StreamingState

java.lang.Object
org.infinispan.server.hotrod.streaming.StreamingState
Direct Known Subclasses:
GetStreamingState, PutStreamingState
public abstract class StreamingState extends Object

  • Constructor Details

    • StreamingState

      public StreamingState(byte[] key, io.netty.channel.Channel channelUsed)

  • Method Details

    • getKey

      public byte[] getKey()

    • valueForPut

      public byte[] valueForPut()

    • metadataForPut

      public Metadata.Builder metadataForPut()

    • versionForPut

      public long versionForPut()

    • nextPut

      public void nextPut(io.netty.buffer.ByteBuf buf)

    • nextGet

      public io.netty.buffer.ByteBuf nextGet()

    • isGetComplete

      public boolean isGetComplete()

    • closePut

      public void closePut()

    • closeGet

      public void closeGet()

    • verifyCorrectThread

      protected void verifyCorrectThread()

    • close

      public abstract void close()