Package io.vertx.rxjava3.sqlclient
Class RowStream<T>
- java.lang.Object
-
- io.vertx.rxjava3.sqlclient.RowStream<T>
-
- All Implemented Interfaces:
io.vertx.lang.rx.RxDelegate,ReadStream<T>,StreamBase
public class RowStream<T> extends Object implements io.vertx.lang.rx.RxDelegate, ReadStream<T>
A row oriented stream.NOTE: This class has been automatically generated from the
originalnon RX-ified interface using Vert.x codegen.
-
-
Field Summary
Fields Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<RowStream>__TYPE_ARGio.vertx.lang.rx.TypeArg<T>__typeArg_0
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Completableclose()Close the stream and release the resources.RowStream<T>endHandler(Handler<Void> endHandler)Set an end handler.booleanequals(Object o)RowStream<T>exceptionHandler(Handler<Throwable> handler)Set an exception handler on the read stream.RowStream<T>fetch(long l)Fetch the specifiedamountof elements.RowStreamgetDelegate()RowStream<T>handler(Handler<T> handler)Set a data handler.inthashCode()static <T> RowStream<T>newInstance(RowStream arg)static <T> RowStream<T>newInstance(RowStream arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)RowStream<T>pause()Pause theReadStream, it sets the buffer infetchmode and clears the actual demand.Pipe<T>pipe()Pause this stream and return a to transfer the elements of this stream to a destination .CompletablepipeTo(WriteStream<T> dst)Pipe thisReadStreamto theWriteStream.RowStream<T>resume()Resume reading, and sets the buffer inflowingmode.CompletablerxClose()Close the stream and release the resources.CompletablerxPipeTo(WriteStream<T> dst)Pipe thisReadStreamto theWriteStream.Flowable<T>toFlowable()Observable<T>toObservable()StringtoString()
-
-
-
Method Detail
-
getDelegate
public RowStream getDelegate()
- Specified by:
getDelegatein interfaceReadStream<T>- Specified by:
getDelegatein interfaceio.vertx.lang.rx.RxDelegate- Specified by:
getDelegatein interfaceStreamBase
-
toObservable
public Observable<T> toObservable()
- Specified by:
toObservablein interfaceReadStream<T>
-
toFlowable
public Flowable<T> toFlowable()
- Specified by:
toFlowablein interfaceReadStream<T>
-
pipe
public Pipe<T> pipe()
Pause this stream and return a to transfer the elements of this stream to a destination . The stream will be resumed when the pipe will be wired to aWriteStream.- Specified by:
pipein interfaceReadStream<T>- Returns:
- a pipe
-
pipeTo
public Completable pipeTo(WriteStream<T> dst)
Pipe thisReadStreamto theWriteStream.Elements emitted by this stream will be written to the write stream until this stream ends or fails.
- Specified by:
pipeToin interfaceReadStream<T>- Parameters:
dst- the destination write stream- Returns:
- a future notified when the write stream will be ended with the outcome
-
rxPipeTo
public Completable rxPipeTo(WriteStream<T> dst)
Pipe thisReadStreamto theWriteStream.Elements emitted by this stream will be written to the write stream until this stream ends or fails.
- Specified by:
rxPipeToin interfaceReadStream<T>- Parameters:
dst- the destination write stream- Returns:
- a future notified when the write stream will be ended with the outcome
-
exceptionHandler
public RowStream<T> exceptionHandler(Handler<Throwable> handler)
Description copied from interface:ReadStreamSet an exception handler on the read stream.- Specified by:
exceptionHandlerin interfaceReadStream<T>- Specified by:
exceptionHandlerin interfaceStreamBase- Parameters:
handler- the exception handler- Returns:
- a reference to this, so the API can be used fluently
-
handler
public RowStream<T> handler(Handler<T> handler)
Description copied from interface:ReadStreamSet a data handler. As data is read, the handler will be called with the data.- Specified by:
handlerin interfaceReadStream<T>- Returns:
- a reference to this, so the API can be used fluently
-
pause
public RowStream<T> pause()
Description copied from interface:ReadStreamPause theReadStream, it sets the buffer infetchmode and clears the actual demand.While it's paused, no data will be sent to the data
handler.- Specified by:
pausein interfaceReadStream<T>- Returns:
- a reference to this, so the API can be used fluently
-
resume
public RowStream<T> resume()
Description copied from interface:ReadStreamResume reading, and sets the buffer inflowingmode. If theReadStreamhas been paused, reading will recommence on it.- Specified by:
resumein interfaceReadStream<T>- Returns:
- a reference to this, so the API can be used fluently
-
endHandler
public RowStream<T> endHandler(Handler<Void> endHandler)
Description copied from interface:ReadStreamSet an end handler. Once the stream has ended, and there is no more data to be read, this handler will be called.- Specified by:
endHandlerin interfaceReadStream<T>- Returns:
- a reference to this, so the API can be used fluently
-
fetch
public RowStream<T> fetch(long l)
Description copied from interface:ReadStreamFetch the specifiedamountof elements. If theReadStreamhas been paused, reading will recommence with the specifiedamountof items, otherwise the specifiedamountwill be added to the current stream demand.- Specified by:
fetchin interfaceReadStream<T>- Returns:
- a reference to this, so the API can be used fluently
-
close
public Completable close()
Close the stream and release the resources.- Returns:
-
rxClose
public Completable rxClose()
Close the stream and release the resources.- Returns:
-
-