tree c4dd56edd83a29c3bf55d84dac6a4e58b4d1194b
parent 6f09bd241179d157a69ae8012c64a6a2d92f972e
author Daniel Santiago Rivera <danysantiago@google.com> 1722373003 -0400
committer Daniel Santiago Rivera <danysantiago@google.com> 1722459782 -0400

Migrate Rx query result adapters to driver APIs

Migrate Rx query adapters by using newly added helper utility functions that can let generated code act on the connection to perform the query while returning the appropriate Rx type.

For the reactive types, Flowable and Observable the coroutine-rx bridges are used to convert from Flow to Rx. While for Single and Maybe a fromCallable builder is used along with performBlocking. This is done to maintain existing behaviour where emitter thread is controlled by subscriber, where as if we use the Coroutines Rx builders in the library, they require a Coroutine context or use Dispatchers.Default causing the actual query to be performed in a background thread not controlled by the subscriber.

Test: DaoKotlinCodeGenTest
Change-Id: I4dad5b8506c366ee3e715ee9e7e3e49ce86a0dd2