Antti Laisi
Antti Laisi
Hi, can you provide a test case for this? Are you trying to use a vector as a parameter (requires extending IPgParameter) or trying to run a constant string sql...
Thanks for the bug report. Can you verify that the exception occurs when using version 0.9 of the library?
Hi, you're correct, but due to backward compatibility I'm hesitant to change observables emitting a single null to Observable.empty(). But for example returning something like `Observable` with onNext(Transaction.State.ACTIVE) from Transaction::begin...
Ok, great. For Single, that will probably be taken into using when porting to RxJava 2.0.
Thanks for the bug report, I'm looking into it.
Hi, does the query-rows fn in master fit your use case? Sample usage: ``` clojure (query-rows! db ["select generate_series(1, $1::int4) as i" 1000]) ```
Short answer: Currently no. Long answer: What timeouts are you referring to? You can of course use core.async (timeout) and (alts!) but there is currently no way to cancel a...
Hi, as @haraldnh pointed out, you won't get any output if the JVM exits before the queries are completed. You can also add a second argument to ```subscribe``` to get...
Hi, the current plan is to extract a "core" library that is built on Netty only (e.g. using Netty promises for async) and then create wrappers for RxJava1/2 and Reactor....
@bnorm sounds great! Create a PR and I'll check it out.