open static fun <T : Any> toObservable(stream: ReadStream<T>): Observable<T>
Adapts a Vert.x < to an RxJava <. After the stream is adapted to an observable, the original stream handlers should not be used anymore as they will be used by the observable adapter.
The adapter supports reactive pull back-pressure.
When back-pressure is enabled, a buffer of ObservableReadStream#DEFAULT_MAX_BUFFER_SIZE items is maintained:
Return
the adapted observable
open static fun <T : Any> toObservable(stream: ReadStream<T>, maxBufferSize: Int): Observable<T>
Adapts a Vert.x < to an RxJava <. After the stream is adapted to an observable, the original stream handlers should not be used anymore as they will be used by the observable adapter.
The adapter supports reactive pull back-pressure.
When back-pressure is enabled, a buffer of maxBufferSize items is maintained:
maxBufferSize - the max size of the buffer used when back-pressure is active
Return
the adapted observable
open static fun <T : Any, R : Any> toObservable(stream: ReadStream<T>, adapter: Function<T, R>): Observable<R>
Like #toObservable(ReadStream) but with a function that adapts the items.
open static fun <T : Any, R : Any> toObservable(stream: ReadStream<T>, adapter: Function<T, R>, maxBufferSize: Int): Observable<R>
Like #toObservable(ReadStream, int) but with a function that adapts the items.