Interface StreamSource<R>

  • All Known Implementing Classes:
    BlockingQueueStreamSource

    public interface StreamSource<R>
    Defines a source of streaming data. A StreamSource implementation is used by BaseStreamStep when loading data from an external stream.
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void close()
      Signals this stream is no longer in use and can clean up resources.
      io.reactivex.Flowable<R> flowable()
      Returns the rows of data as an iterable.
      void open()
      Open the source for loading rows.
      void pause()
      Causes the stream to stop accepting new input.
      void resume()
      Resumes accepting input if paused, otherwise noop.
    • Method Detail

      • flowable

        io.reactivex.Flowable<R> flowable()
        Returns the rows of data as an iterable.
      • close

        void close()
        Signals this stream is no longer in use and can clean up resources.
      • pause

        void pause()
        Causes the stream to stop accepting new input.
      • resume

        void resume()
        Resumes accepting input if paused, otherwise noop.
      • open

        void open()
        Open the source for loading rows. Used for initializing resources required to load the stream.