org.infinispan.client.hotrod.impl.protocol

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

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME

Fields inherited from class org.infinispan.client.hotrod.impl.protocol.AbstractVersionedInputStream

afterClose, versionedMetadata

Constructor Summary

Constructors

Constructor and Description
ChannelInputStream(VersionedMetadata versionedMetadata, Runnable afterClose, int totalLength)

Method Summary

Modifier and Type	Method and 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, read, reset, skip

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 class InputStream

Throws:

IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)
                 throws Exception

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Specified by:

channelRead in interface ChannelInboundHandlerDefaults

Throws:

Exception

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                            Throwable cause)
                     throws Exception

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Specified by:

exceptionCaught in interface ChannelInboundHandlerDefaults

Throws:

Exception

userEventTriggered

public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx,
                               Object evt)
                        throws Exception

Specified by:

userEventTriggered in interface io.netty.channel.ChannelInboundHandler

Specified by:

userEventTriggered in interface ChannelInboundHandlerDefaults

Throws:

Exception

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractVersionedInputStream

Throws:

IOException

moveReadable

public boolean moveReadable(io.netty.buffer.ByteBuf buf)