Package org.aksw.commons.io.input

Class SeekableReadableChannelWithMonitor<A,X extends SeekableReadableChannel<A>>

java.lang.Object

org.aksw.commons.util.closeable.AutoCloseableWrapperBase<X>

org.aksw.commons.io.shared.ChannelDecoratorBase<X>

org.aksw.commons.io.input.ReadableChannelDecoratorBase<A,X>

org.aksw.commons.io.input.SeekableReadableChannelDecoratorBase<A,X>

org.aksw.commons.io.input.SeekableReadableChannelWithMonitor<A,X>

All Implemented Interfaces:

Closeable, AutoCloseable, Cloneable, Channel, HasArrayOps<A>, HasPosition, ReadableChannel<A>, ReadableSource<A>, SeekableReadableChannel<A>

public class SeekableReadableChannelWithMonitor<A,X extends SeekableReadableChannel<A>>
extends SeekableReadableChannelDecoratorBase<A,X>

Field Summary

Fields

Modifier and Type	Field	Description
protected long	cachedPos
protected ChannelMonitor2	monitor
protected long	readCounter
protected long	readLength
protected long	relativeStart

Fields inherited from class org.aksw.commons.util.closeable.AutoCloseableWrapperBase

delegate

Constructor Summary

Constructors

Constructor	Description
SeekableReadableChannelWithMonitor(X delegate, ChannelMonitor2 monitor)

Method Summary

Modifier and Type	Method	Description
void	position(long pos)
int	read(A array, int position, int length)	Read method following the usual InputStream protocol.

Methods inherited from class org.aksw.commons.io.input.SeekableReadableChannelDecoratorBase

cloneObject, getArrayOps, position

Methods inherited from class org.aksw.commons.io.shared.ChannelDecoratorBase

close, isOpen

Methods inherited from class org.aksw.commons.util.closeable.AutoCloseableWrapperBase

close, getDelegate

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.nio.channels.Channel

close, isOpen

Methods inherited from interface org.aksw.commons.io.input.ReadableSource

readRaw

Field Details

monitor

protected ChannelMonitor2 monitor

cachedPos

protected long cachedPos

relativeStart

protected long relativeStart

readLength

protected long readLength

readCounter

protected volatile long readCounter

Constructor Details

SeekableReadableChannelWithMonitor

public SeekableReadableChannelWithMonitor(X delegate,
 ChannelMonitor2 monitor)

Method Details

read

public int read(A array,
 int position,
 int length)
         throws IOException

Description copied from interface: ReadableSource

Read method following the usual InputStream protocol.

Specified by:

read in interface ReadableSource<A>

Overrides:

read in class SeekableReadableChannelDecoratorBase<A,X extends SeekableReadableChannel<A>>

Parameters:

array - The array into which to put the read data

position - Offset into array where to start writing

length - Maximum number of items to read.

Returns:

The number of items read. Return -1 if end of data was reached, and 0 iff length was 0.

Throws:

IOException

position

public void position(long pos)
              throws IOException

Specified by:

position in interface HasPosition

Overrides:

position in class SeekableReadableChannelDecoratorBase<A,X extends SeekableReadableChannel<A>>

Throws:

IOException