DisposableStream.md

com.industry.rx_epl.DisposableStream <>

Wrapper for a stream to allow the stream and the observable to be terminated together. Returned by calls to .toStream(...).

Methods

• GetStream
• Dispose

# .getStream() returns stream<any> <>

Access the stream<any>.

Note: .dispose() should be used rather than stream.quit().

DisposableStream ds := Observable.interval(1.0)
	.toStream();

stream<any> strm := ds.getStream();

stream<integer> intStream := from v in strm select <integer> v;

# .dispose() <>

Dispose of a stream and the observable source.

Note: Calls stream.quit() which will terminate any stream listeners.

DisposableStream ds:= Observable.interval(1.0)
	.toStream();

ds.dispose(); // Terminate the observable and the stream.