Package org.aksw.commons.rx.io

Class SequentialReaderRx<A>

java.lang.Object
org.aksw.commons.util.closeable.AutoCloseableBase
org.aksw.commons.util.closeable.AutoCloseableWithLeakDetectionBase
org.aksw.commons.rx.io.SequentialReaderRx<A>
All Implemented Interfaces:
Closeable, AutoCloseable, Channel, org.aksw.commons.io.buffer.array.HasArrayOps<A>, org.aksw.commons.io.input.ReadableChannel<A>, org.aksw.commons.io.input.ReadableSource<A>
public class SequentialReaderRx<A> extends org.aksw.commons.util.closeable.AutoCloseableWithLeakDetectionBase implements org.aksw.commons.io.input.ReadableChannel<A>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected org.aksw.commons.io.buffer.array.ArrayOps<A>
    arrayOps
     
    protected io.reactivex.rxjava3.disposables.Disposable
    disposable
     
    protected io.reactivex.rxjava3.core.Flowable<?>
    flowable
     
    protected Iterator<?>
    iterator
     

    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
    SequentialReaderRx(io.reactivex.rxjava3.core.Flowable<?> flowable, org.aksw.commons.io.buffer.array.ArrayOps<A> arrayOps)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    closeActual()
     
    org.aksw.commons.io.buffer.array.ArrayOps<A>
    getArrayOps()
     
    boolean
    isOpen()
     
    boolean
    isStarted()
     
    int
    read(A array, int position, int length)
     
    void
    start()
     

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

    finalize, getInstantiationStackTrace

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

    close, 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

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

    readRaw

  • Field Details

    • flowable

      protected io.reactivex.rxjava3.core.Flowable<?> flowable

    • arrayOps

      protected org.aksw.commons.io.buffer.array.ArrayOps<A> arrayOps

    • iterator

      protected Iterator<?> iterator

    • disposable

      protected io.reactivex.rxjava3.disposables.Disposable disposable

  • Constructor Details

    • SequentialReaderRx

      public SequentialReaderRx(io.reactivex.rxjava3.core.Flowable<?> flowable, org.aksw.commons.io.buffer.array.ArrayOps<A> arrayOps)

  • Method Details

    • start

      public void start()

    • isStarted

      public boolean isStarted()

    • closeActual

      public void closeActual() throws IOException
      Overrides:
      closeActual in class org.aksw.commons.util.closeable.AutoCloseableBase
      Throws:
      IOException

    • read

      public int read(A array, int position, int length) throws IOException
      Specified by:
      read in interface org.aksw.commons.io.input.ReadableSource<A>
      Throws:
      IOException

    • getArrayOps

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

    • isOpen

      public boolean isOpen()
      Specified by:
      isOpen in interface Channel