Package org.aksw.commons.io.input

Class ReadableChannelOverReadableSource<A>

java.lang.Object
org.aksw.commons.util.closeable.AutoCloseableBase
org.aksw.commons.util.closeable.AutoCloseableWithLeakDetectionBase
org.aksw.commons.io.shared.ChannelBase
org.aksw.commons.io.input.ReadableChannelBase<A>
org.aksw.commons.io.input.ReadableChannelOverReadableSource<A>
Type Parameters:
A -
All Implemented Interfaces:
Closeable, AutoCloseable, Channel, HasArrayOps<A>, ReadableChannel<A>, ReadableSource<A>
public class ReadableChannelOverReadableSource<A> extends ReadableChannelBase<A>
The channel adds the open/close mechanic.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected ReadableSource<A>
    source
     

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

    instantiationStackTrace

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

    closeStackTrace, enableCloseStackTrace, isClosed

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReadableChannelOverReadableSource(ReadableSource<A> source)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    ArrayOps<A>
    getArrayOps()
     
    int
    read(A array, int position, int length)
    Read method following the usual InputStream protocol.

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

    isOpen

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

    finalize, getInstantiationStackTrace

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

    close, closeActual, ensureOpen, throwClosedException

    Methods inherited from class java.lang.Object

    clone, equals, 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

  • Constructor Details

    • ReadableChannelOverReadableSource

      public ReadableChannelOverReadableSource(ReadableSource<A> source)

  • 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.
      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

    • getArrayOps

      public ArrayOps<A> getArrayOps()