Efficient execution and functional composition of database calls using jdbc and RxJava Observables
APACHE-2.0 License
Published by davidmoten over 9 years ago
SQLException
with RuntimeException
wrap with SQLRuntimeException
Published by davidmoten over 9 years ago
Published by davidmoten over 9 years ago
QuerySelect.Builder.get
now requires a ResultSetMapper<T>
instead of a Func1<ResultSet,T>
. This is a breaking change.@Query
annotation, see autoMap doco on README.mdPublished by davidmoten over 9 years ago
autoMap
). See README for detailsObservable.retry
)Published by davidmoten over 9 years ago
Long.MAX_VALUE
can end up both emitting on fast pathBackpressureUtils
copied from rxjava internalsQuerySelectProducer
Published by davidmoten over 9 years ago
Database.asynchronous()
overloads so can specify Scheduler
. See #16Published by davidmoten over 9 years ago
SingleSubscribeSubject
compareAndSet
instead of synchronized
to improve concurrent performance of ConnectionProviderSingletonManualCommmit
Published by davidmoten over 9 years ago
PublishSubject
in OperationToOperator
Published by davidmoten over 9 years ago
Published by davidmoten over 9 years ago
Published by davidmoten over 9 years ago
Published by davidmoten almost 10 years ago
io.reactivex:rxjava:1.0.1
Published by davidmoten about 10 years ago
Published by davidmoten about 10 years ago
Published by davidmoten about 10 years ago
flatMap
with concatMap
to limit possible async side effects on specifying parameter observables to queriesPublished by davidmoten about 10 years ago
Database.Builder
method for specifying connection poolDatabase.Builder
, Database.from()