Package org.aksw.commons.rx.io

Class ReadableChannelSourceRx<T>

java.lang.Object
org.aksw.commons.rx.io.ReadableChannelSourceRx<T>
All Implemented Interfaces:
org.aksw.commons.io.buffer.array.HasArrayOps<T[]>, org.aksw.commons.io.input.ReadableChannelFactory<T[]>, org.aksw.commons.io.input.ReadableChannelSource<T[]>
public class ReadableChannelSourceRx<T> extends Object implements org.aksw.commons.io.input.ReadableChannelSource<T[]>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected org.aksw.commons.io.buffer.array.ArrayOps<T[]>
    arrayOps
     
    protected ListPaginator<T>
    listPaginator
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReadableChannelSourceRx(org.aksw.commons.io.buffer.array.ArrayOps<T[]> arrayOps, ListPaginator<T> listPaginator)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T> org.aksw.commons.io.input.ReadableChannelSource<T[]>
    create(org.aksw.commons.io.buffer.array.ArrayOps<T[]> arrayOps, ListPaginator<T> listPaginator)
     
    org.aksw.commons.io.buffer.array.ArrayOps<T[]>
    getArrayOps()
     
    org.aksw.commons.io.input.ReadableChannel<T[]>
    newReadableChannel(com.google.common.collect.Range<Long> range)
     
    long
    size()
     

    Methods inherited from class java.lang.Object

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

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

    newReadableChannel, newReadableChannel

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

    newReadableChannel

  • Field Details

    • arrayOps

      protected org.aksw.commons.io.buffer.array.ArrayOps<T[]> arrayOps

    • listPaginator

      protected ListPaginator<T> listPaginator

  • Constructor Details

    • ReadableChannelSourceRx

      public ReadableChannelSourceRx(org.aksw.commons.io.buffer.array.ArrayOps<T[]> arrayOps, ListPaginator<T> listPaginator)

  • Method Details

    • getArrayOps

      public org.aksw.commons.io.buffer.array.ArrayOps<T[]> getArrayOps()
      Specified by:
      getArrayOps in interface org.aksw.commons.io.buffer.array.HasArrayOps<T>

    • create

      public static <T> org.aksw.commons.io.input.ReadableChannelSource<T[]> create(org.aksw.commons.io.buffer.array.ArrayOps<T[]> arrayOps, ListPaginator<T> listPaginator)

    • newReadableChannel

      public org.aksw.commons.io.input.ReadableChannel<T[]> newReadableChannel(com.google.common.collect.Range<Long> range)
      Specified by:
      newReadableChannel in interface org.aksw.commons.io.input.ReadableChannelFactory<T>

    • size

      public long size()
      Specified by:
      size in interface org.aksw.commons.io.input.ReadableChannelSource<T>