Package io.vertx.rxjava3.cassandra
Class CassandraRowStream
- java.lang.Object
-
- io.vertx.rxjava3.cassandra.CassandraRowStream
-
- All Implemented Interfaces:
io.vertx.lang.rx.RxDelegate,ReadStream<com.datastax.oss.driver.api.core.cql.Row>,StreamBase
public class CassandraRowStream extends Object implements io.vertx.lang.rx.RxDelegate, ReadStream<com.datastax.oss.driver.api.core.cql.Row>
A for consumption.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<CassandraRowStream>__TYPE_ARG
-
Constructor Summary
Constructors Constructor Description CassandraRowStream(CassandraRowStream delegate)CassandraRowStream(Object delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description com.datastax.oss.driver.api.core.cql.ColumnDefinitionscolumnDefinitions()Get the provided by the backingResultSetfor this stream.CassandraRowStreamendHandler(Handler<Void> handler)Set an end handler.booleanequals(Object o)CassandraRowStreamexceptionHandler(Handler<Throwable> handler)Set an exception handler on the read stream.com.datastax.oss.driver.api.core.cql.ExecutionInfoexecutionInfo()Get the provided by the backingResultSetfor this stream.CassandraRowStreamfetch(long l)Fetch the specifiedamountof elements.CassandraRowStreamgetDelegate()CassandraRowStreamhandler(Handler<com.datastax.oss.driver.api.core.cql.Row> handler)Set a data handler.inthashCode()static CassandraRowStreamnewInstance(CassandraRowStream arg)CassandraRowStreampause()Pause theReadStream, it sets the buffer infetchmode and clears the actual demand.Pipe<com.datastax.oss.driver.api.core.cql.Row>pipe()Pause this stream and return a to transfer the elements of this stream to a destination .CompletablepipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)Pipe thisReadStreamto theWriteStream.CassandraRowStreamresume()Resume reading, and sets the buffer inflowingmode.CompletablerxPipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)Pipe thisReadStreamto theWriteStream.Flowable<com.datastax.oss.driver.api.core.cql.Row>toFlowable()Observable<com.datastax.oss.driver.api.core.cql.Row>toObservable()StringtoString()
-
-
-
Field Detail
-
__TYPE_ARG
public static final io.vertx.lang.rx.TypeArg<CassandraRowStream> __TYPE_ARG
-
-
Constructor Detail
-
CassandraRowStream
public CassandraRowStream(CassandraRowStream delegate)
-
CassandraRowStream
public CassandraRowStream(Object delegate)
-
-
Method Detail
-
getDelegate
public CassandraRowStream getDelegate()
- Specified by:
getDelegatein interfaceReadStream<com.datastax.oss.driver.api.core.cql.Row>- Specified by:
getDelegatein interfaceio.vertx.lang.rx.RxDelegate- Specified by:
getDelegatein interfaceStreamBase
-
toObservable
public Observable<com.datastax.oss.driver.api.core.cql.Row> toObservable()
- Specified by:
toObservablein interfaceReadStream<com.datastax.oss.driver.api.core.cql.Row>
-
toFlowable
public Flowable<com.datastax.oss.driver.api.core.cql.Row> toFlowable()
- Specified by:
toFlowablein interfaceReadStream<com.datastax.oss.driver.api.core.cql.Row>
-
pipe
public Pipe<com.datastax.oss.driver.api.core.cql.Row> 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<com.datastax.oss.driver.api.core.cql.Row>- Returns:
- a pipe
-
exceptionHandler
public CassandraRowStream exceptionHandler(Handler<Throwable> handler)
Description copied from interface:ReadStreamSet an exception handler on the read stream.- Specified by:
exceptionHandlerin interfaceReadStream<com.datastax.oss.driver.api.core.cql.Row>- Specified by:
exceptionHandlerin interfaceStreamBase- Parameters:
handler- the exception handler- Returns:
- a reference to this, so the API can be used fluently
-
pause
public CassandraRowStream 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<com.datastax.oss.driver.api.core.cql.Row>- Returns:
- a reference to this, so the API can be used fluently
-
resume
public CassandraRowStream 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<com.datastax.oss.driver.api.core.cql.Row>- Returns:
- a reference to this, so the API can be used fluently
-
endHandler
public CassandraRowStream endHandler(Handler<Void> handler)
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<com.datastax.oss.driver.api.core.cql.Row>- Returns:
- a reference to this, so the API can be used fluently
-
fetch
public CassandraRowStream 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<com.datastax.oss.driver.api.core.cql.Row>- Returns:
- a reference to this, so the API can be used fluently
-
handler
public CassandraRowStream handler(Handler<com.datastax.oss.driver.api.core.cql.Row> 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<com.datastax.oss.driver.api.core.cql.Row>- Returns:
- a reference to this, so the API can be used fluently
-
pipeTo
public Completable pipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst)
Description copied from interface:ReadStreamPipe thisReadStreamto theWriteStream.Elements emitted by this stream will be written to the write stream until this stream ends or fails.
- Specified by:
pipeToin interfaceReadStream<com.datastax.oss.driver.api.core.cql.Row>- 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<com.datastax.oss.driver.api.core.cql.Row> dst)
Description copied from interface:ReadStreamPipe thisReadStreamto theWriteStream.Elements emitted by this stream will be written to the write stream until this stream ends or fails.
- Specified by:
rxPipeToin interfaceReadStream<com.datastax.oss.driver.api.core.cql.Row>- Parameters:
dst- the destination write stream- Returns:
- a future notified when the write stream will be ended with the outcome
-
executionInfo
public com.datastax.oss.driver.api.core.cql.ExecutionInfo executionInfo()
Get the provided by the backingResultSetfor this stream.- Returns:
-
columnDefinitions
public com.datastax.oss.driver.api.core.cql.ColumnDefinitions columnDefinitions()
Get the provided by the backingResultSetfor this stream.- Returns:
-
newInstance
public static CassandraRowStream newInstance(CassandraRowStream arg)
-
-