io.reactiverse.reactivex.neo4j

Class Neo4jTransaction

java.lang.Object

io.reactiverse.reactivex.neo4j.Neo4jTransaction

public class Neo4jTransaction
extends Object

Eclipse Vert.x Neo4j client.

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<Neo4jTransaction>	__TYPE_ARG

Constructor Summary

Constructors

Constructor and Description
Neo4jTransaction(Neo4jTransaction delegate)
Neo4jTransaction(Object delegate)

Method Summary

Modifier and Type	Method and Description
Neo4jTransaction	commit(Handler<AsyncResult<Void>> resultHandler) Commits the transaction
boolean	equals(Object o)
Neo4jTransaction	getDelegate()
int	hashCode()
static Neo4jTransaction	newInstance(Neo4jTransaction arg)
Neo4jTransaction	query(Query query, Handler<AsyncResult<ResultSummary>> resultHandler) Executes a query in a transaction
Neo4jTransaction	query(String query, Value parameters, Handler<AsyncResult<ResultSummary>> resultHandler) Executes a query in a transaction
Neo4jTransaction	readQuery(Query query, Handler<AsyncResult<List<Record>>> resultHandler) Executes a read query in a transaction
Neo4jTransaction	rollback(Handler<AsyncResult<Void>> resultHandler) Rollbacks the transaction
Completable	rxCommit() Commits the transaction
Single<ResultSummary>	rxQuery(Query query) Executes a query in a transaction
Single<ResultSummary>	rxQuery(String query, Value parameters) Executes a query in a transaction
Single<List<Record>>	rxReadQuery(Query query) Executes a read query in a transaction
Completable	rxRollback() Rollbacks the transaction
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

__TYPE_ARG

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

Constructor Detail

Neo4jTransaction

public Neo4jTransaction(Neo4jTransaction delegate)

Neo4jTransaction

public Neo4jTransaction(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 Neo4jTransaction getDelegate()

commit

public Neo4jTransaction commit(Handler<AsyncResult<Void>> resultHandler)

Commits the transaction

Parameters:

resultHandler - the handler to be notified when the transaction commit has completed

Returns:

the current Neo4jTransaction instance

rxCommit

public Completable rxCommit()

Commits the transaction

Returns:

the current Neo4jTransaction instance

rollback

public Neo4jTransaction rollback(Handler<AsyncResult<Void>> resultHandler)

Rollbacks the transaction

Parameters:

resultHandler - the handler to be notified when the transaction rollback has completed

Returns:

the current Neo4jTransaction instance

rxRollback

public Completable rxRollback()

Rollbacks the transaction

Returns:

the current Neo4jTransaction instance

query

public Neo4jTransaction query(String query,
                              Value parameters,
                              Handler<AsyncResult<ResultSummary>> resultHandler)

Executes a query in a transaction

Parameters:

query - the cypher query

parameters - the cypher parameters

resultHandler - the handler to be called when the query has completed

Returns:

the current Neo4jTransaction instance

rxQuery

public Single<ResultSummary> rxQuery(String query,
                                     Value parameters)

Executes a query in a transaction

Parameters:

query - the cypher query

parameters - the cypher parameters

Returns:

the current Neo4jTransaction instance

query

public Neo4jTransaction query(Query query,
                              Handler<AsyncResult<ResultSummary>> resultHandler)

Executes a query in a transaction

Parameters:

query - the cypher statement

resultHandler - the handler to be called when the query has completed

Returns:

the current Neo4jTransaction instance

rxQuery

public Single<ResultSummary> rxQuery(Query query)

Executes a query in a transaction

Parameters:

query - the cypher statement

Returns:

the current Neo4jTransaction instance

readQuery

public Neo4jTransaction readQuery(Query query,
                                  Handler<AsyncResult<List<Record>>> resultHandler)

Executes a read query in a transaction

Parameters:

query - the cypher statement

resultHandler - the handler to be called when the query has completed

Returns:

the current Neo4jTransaction instance

rxReadQuery

public Single<List<Record>> rxReadQuery(Query query)

Executes a read query in a transaction

Parameters:

query - the cypher statement

Returns:

the current Neo4jTransaction instance

newInstance

public static Neo4jTransaction newInstance(Neo4jTransaction arg)