Class ChannelInputStream
- java.lang.Object
-
- java.io.InputStream
-
- org.infinispan.client.hotrod.impl.protocol.AbstractVersionedInputStream
-
- org.infinispan.client.hotrod.impl.protocol.ChannelInputStream
-
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
,Closeable
,AutoCloseable
,ChannelInboundHandlerDefaults
,Metadata
,Versioned
,VersionedMetadata
public class ChannelInputStream extends AbstractVersionedInputStream implements ChannelInboundHandlerDefaults
-
-
Field Summary
Fields Modifier and Type Field Description static String
NAME
-
Fields inherited from class org.infinispan.client.hotrod.impl.protocol.AbstractVersionedInputStream
afterClose, versionedMetadata
-
-
Constructor Summary
Constructors Constructor Description ChannelInputStream(VersionedMetadata versionedMetadata, Runnable afterClose, int totalLength)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
void
close()
void
exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
boolean
moveReadable(io.netty.buffer.ByteBuf buf)
int
read()
int
read(byte[] b, int off, int len)
void
userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)
-
Methods inherited from class org.infinispan.client.hotrod.impl.protocol.AbstractVersionedInputStream
getCreated, getLastUsed, getLifespan, getMaxIdle, getVersion
-
Methods inherited from class java.io.InputStream
available, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.infinispan.client.hotrod.impl.transport.netty.ChannelInboundHandlerDefaults
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, handlerAdded, handlerRemoved
-
-
-
-
Field Detail
-
NAME
public static final String NAME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ChannelInputStream
public ChannelInputStream(VersionedMetadata versionedMetadata, Runnable afterClose, int totalLength)
-
-
Method Detail
-
read
public int read() throws IOException
- Specified by:
read
in classInputStream
- Throws:
IOException
-
read
public int read(byte[] b, int off, int len) throws IOException
- Overrides:
read
in classInputStream
- Throws:
IOException
-
channelRead
public void channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg) throws Exception
- Specified by:
channelRead
in interfaceio.netty.channel.ChannelInboundHandler
- Specified by:
channelRead
in interfaceChannelInboundHandlerDefaults
- Throws:
Exception
-
exceptionCaught
public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause) throws Exception
- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelHandler
- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelInboundHandler
- Specified by:
exceptionCaught
in interfaceChannelInboundHandlerDefaults
- Throws:
Exception
-
userEventTriggered
public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt) throws Exception
- Specified by:
userEventTriggered
in interfaceio.netty.channel.ChannelInboundHandler
- Specified by:
userEventTriggered
in interfaceChannelInboundHandlerDefaults
- Throws:
Exception
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classAbstractVersionedInputStream
- Throws:
IOException
-
moveReadable
public boolean moveReadable(io.netty.buffer.ByteBuf buf)
-
-