StreamSource (PDI Engine 9.3.0.0-424 API)

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.