Click or drag to resize

IRxSession Methods

The IRxSession type exposes the following members.

Methods
  NameDescription
Public methodBeginTransaction
Begin a new explicitIRxTransaction. Actual transaction is only created once an observer is subscribed to the returned reactive stream. A session instance can only have at most one transaction at a time. If you want to run multiple concurrent transactions, you should use multiple concurrent sessions.
Public methodBeginTransaction(ActionTransactionConfigBuilder)
Begin a new explicitIRxTransaction with the provided TransactionConfig. Actual transaction is only created once an observer is subscribed to the returned reactive stream. A session instance can only have at most one transaction at a time. If you want to run multiple concurrent transactions, you should use multiple concurrent sessions.
Public methodCloseT
Closes this session and returns an empty reactive stream. The type parameter makes it easier to chain this method to other reactive streams.
Public methodReadTransactionT(FuncIRxTransaction, IObservableT)
Execute the provided unit of work in a Readreactive transaction.
Public methodReadTransactionT(FuncIRxTransaction, IObservableT, ActionTransactionConfigBuilder)
Execute the provided unit of work in a Readreactive transaction which is created with the provided TransactionConfig.
Public methodRun(String)
Create a reactive result that will execute the query.
(Inherited from IRxRunnable.)
Public methodRun(Query)
Create a reactive result that will execute the given query. The query is only executed when an IObserverT is subscribed to one of the reactive streams that can be accessed through the returned reactive result.
(Inherited from IRxRunnable.)
Public methodRun(String, Object)
Create a reactive result that will execute the query with the specified parameters.
(Inherited from IRxRunnable.)
Public methodRun(String, ActionTransactionConfigBuilder)
Create a reactive result that will execute the query with the provided TransactionConfig that applies to the underlying auto-commit transaction.
Public methodRun(Query, ActionTransactionConfigBuilder)
Create a reactive result that will execute the given query with the provided TransactionConfig that applies to the underlying auto-commit transaction. The query is only executed when an IObserverT is subscribed to one of the reactive streams that can be accessed through the returned reactive result.
Public methodRun(String, Object, ActionTransactionConfigBuilder)
Create a reactive result that will execute the query with the specified parameters and the provided TransactionConfig that applies to the underlying auto-commit transaction.
Public methodWriteTransactionT(FuncIRxTransaction, IObservableT)
Execute the provided unit of work in a Readreactive transaction.
Public methodWriteTransactionT(FuncIRxTransaction, IObservableT, ActionTransactionConfigBuilder)
Execute the provided unit of work in a Readreactive transaction which is created with the provided TransactionConfig.
Top
See Also