java.lang.Object
org.neo4j.driver.internal.reactive.AbstractReactiveTransaction
org.neo4j.driver.internal.reactive.InternalRxTransaction
- All Implemented Interfaces:
RxQueryRunner
,RxTransaction
@Deprecated
public class InternalRxTransaction
extends AbstractReactiveTransaction
implements RxTransaction
Deprecated.
-
Field Summary
Fields inherited from class org.neo4j.driver.internal.reactive.AbstractReactiveTransaction
tx
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.reactivestreams.Publisher<Void>
close()
Deprecated.Close the transaction.<T> org.reactivestreams.Publisher<T>
commit()
Deprecated.Commits the transaction.org.reactivestreams.Publisher<Boolean>
isOpen()
Deprecated.Determine if transaction is open.<T> org.reactivestreams.Publisher<T>
rollback()
Deprecated.Rolls back the transaction.Deprecated.Register running of a query and return a reactive result stream.Methods inherited from class org.neo4j.driver.internal.reactive.AbstractReactiveTransaction
close, doClose, doCommit, doIsOpen, doRollback
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.neo4j.driver.reactive.RxQueryRunner
run, run, run, run
-
Constructor Details
-
InternalRxTransaction
Deprecated.
-
-
Method Details
-
run
Deprecated.Description copied from interface:RxQueryRunner
Register running of a query and return a reactive result stream. The query is not executed when the reactive result is returned. Instead, the publishers in the result will actually start the execution of the query.- Specified by:
run
in interfaceRxQueryRunner
- Parameters:
query
- a Neo4j query- Returns:
- a reactive result.
-
commit
public <T> org.reactivestreams.Publisher<T> commit()Deprecated.Description copied from interface:RxTransaction
Commits the transaction. It completes without publishing anything if transaction is committed successfully. Otherwise, errors when there is any error to commit.- Specified by:
commit
in interfaceRxTransaction
- Type Parameters:
T
- makes it easier to be chained after other publishers.- Returns:
- an empty publisher.
-
rollback
public <T> org.reactivestreams.Publisher<T> rollback()Deprecated.Description copied from interface:RxTransaction
Rolls back the transaction. It completes without publishing anything if transaction is rolled back successfully. Otherwise, errors when there is any error to roll back.- Specified by:
rollback
in interfaceRxTransaction
- Type Parameters:
T
- makes it easier to be chained after other publishers.- Returns:
- an empty publisher.
-
close
Deprecated.Description copied from interface:RxTransaction
Close the transaction. If the transaction has beencommitted
orrolled back
, the close is optional and no operation is performed. Otherwise, the transaction will be rolled back by default by this method.- Specified by:
close
in interfaceRxTransaction
- Returns:
- new
Publisher
that gets completed when close is successful, otherwise an error is signalled.
-
isOpen
Deprecated.Description copied from interface:RxTransaction
Determine if transaction is open.- Specified by:
isOpen
in interfaceRxTransaction
- Returns:
- a publisher emitting
true
if transaction is open andfalse
otherwise.
-