io.reactiverse.rxjava.neo4j

Class Neo4jRecordStream

java.lang.Object

io.reactiverse.rxjava.neo4j.Neo4jRecordStream

All Implemented Interfaces:

ReadStream<Record>, StreamBase

public class Neo4jRecordStream
extends Object
implements ReadStream<Record>

A for consumption.

NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

Field Summary

Fields

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<Neo4jRecordStream>	__TYPE_ARG

Constructor Summary

Constructors

Constructor and Description
Neo4jRecordStream(Neo4jRecordStream delegate)
Neo4jRecordStream(Object delegate)

Method Summary

Modifier and Type	Method and Description
Neo4jRecordStream	endHandler(Handler<Void> handler)
boolean	equals(Object o)
Neo4jRecordStream	exceptionHandler(Handler<Throwable> handler)
Neo4jRecordStream	fetch(long l)
Neo4jRecordStream	getDelegate()
Neo4jRecordStream	handler(Handler<Record> handler)
int	hashCode()
static Neo4jRecordStream	newInstance(Neo4jRecordStream arg)
Neo4jRecordStream	pause()
Pipe<Record>	pipe()
void	pipeTo(WriteStream<Record> dst)
void	pipeTo(WriteStream<Record> dst, Handler<AsyncResult<Void>> handler)
Neo4jRecordStream	resume()
Single<Void>	rxPipeTo(WriteStream<Record> dst)
Observable<Record>	toObservable()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.vertx.rxjava.core.streams.ReadStream

newInstance, newInstance

Methods inherited from interface io.vertx.rxjava.core.streams.StreamBase

newInstance

Field Detail

__TYPE_ARG

public static final io.vertx.lang.rx.TypeArg<Neo4jRecordStream> __TYPE_ARG

Constructor Detail

Neo4jRecordStream

public Neo4jRecordStream(Neo4jRecordStream delegate)

Neo4jRecordStream

public Neo4jRecordStream(Object delegate)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getDelegate

public Neo4jRecordStream getDelegate()

Specified by:

getDelegate in interface ReadStream<Record>

Specified by:

getDelegate in interface StreamBase

toObservable

public Observable<Record> toObservable()

Specified by:

toObservable in interface ReadStream<Record>

pipe

public Pipe<Record> pipe()

Specified by:

pipe in interface ReadStream<Record>

pipeTo

public void pipeTo(WriteStream<Record> dst)

Specified by:

pipeTo in interface ReadStream<Record>

pipeTo

public void pipeTo(WriteStream<Record> dst,
                   Handler<AsyncResult<Void>> handler)

Specified by:

pipeTo in interface ReadStream<Record>

rxPipeTo

public Single<Void> rxPipeTo(WriteStream<Record> dst)

exceptionHandler

public Neo4jRecordStream exceptionHandler(Handler<Throwable> handler)

Specified by:

exceptionHandler in interface ReadStream<Record>

Specified by:

exceptionHandler in interface StreamBase

pause

public Neo4jRecordStream pause()

Specified by:

pause in interface ReadStream<Record>

resume

public Neo4jRecordStream resume()

Specified by:

resume in interface ReadStream<Record>

endHandler

public Neo4jRecordStream endHandler(Handler<Void> handler)

Specified by:

endHandler in interface ReadStream<Record>

fetch

public Neo4jRecordStream fetch(long l)

Specified by:

fetch in interface ReadStream<Record>

handler

public Neo4jRecordStream handler(Handler<Record> handler)

Specified by:

handler in interface ReadStream<Record>

newInstance

public static Neo4jRecordStream newInstance(Neo4jRecordStream arg)