- All Superinterfaces:
RxQueryRunner
- All Known Implementing Classes:
InternalRxTransaction
Deprecated.
Same as
Transaction
except this reactive transaction exposes a reactive API.- Since:
- 4.0
- See Also:
-
Transaction
RxSession
Publisher
-
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.
-
Method Details
-
commit
<T> org.reactivestreams.Publisher<T> commit()Deprecated.Commits the transaction. It completes without publishing anything if transaction is committed successfully. Otherwise, errors when there is any error to commit.- Type Parameters:
T
- makes it easier to be chained after other publishers.- Returns:
- an empty publisher.
-
rollback
<T> org.reactivestreams.Publisher<T> rollback()Deprecated.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.- Type Parameters:
T
- makes it easier to be chained after other publishers.- Returns:
- an empty publisher.
-
close
org.reactivestreams.Publisher<Void> close()Deprecated.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.- Returns:
- new
Publisher
that gets completed when close is successful, otherwise an error is signalled.
-
isOpen
org.reactivestreams.Publisher<Boolean> isOpen()Deprecated.Determine if transaction is open.- Returns:
- a publisher emitting
true
if transaction is open andfalse
otherwise.
-
ReactiveTransaction
andReactiveTransaction