baku-toolkit/lib/src/main/java/io/v/baku/toolkit/syncbase/BakuTable.java
/**
     * While the default implementation of {@link RxTable#exec(Func1)} provides an autoConnect
     * observable that requires an explicit subscription, this implementation auto-subscribes the
     * default Baku error handler and immediately begins the requested operation. An explicit
     * subscription unsubscribes the default error handler, and should include its own error
     * handler, which may still be the default error handler.
     */
While the default implementation of  RxTable#exec(Func1) provides an autoConnect
observable that requires an explicit subscription, this implementation auto-subscribes the
default Baku error handler and immediately begins the requested operation. An explicit
subscription unsubscribes the default error handler, and should include its own error
handler, which may still be the default error handler.
While the default implementation of RxTable#exec ( Func1 ) provides an autoConnect observable that requires an explicit subscription this implementation auto - subscribes the default Baku error handler and immediately begins the requested operation . An explicit subscription unsubscribes the default error handler and should include its own error handler which may still be the default error handler .
@Override
    public <T> Observable<T> exec(final Func1<Table, ListenableFuture<T>> op) {
        final Observable<T> exec = super.exec(op);
        final Subscription defaultSubscription = exec.subscribe(x -> {
        }, mBakuContext::onSyncError);
        return withActivityLifecycle(exec.doOnSubscribe(defaultSubscription::unsubscribe));
    }
@ Override public < T > Observable < T > exec ( final Func1 < Table , ListenableFuture < T > > op ) { final Observable < T > exec = super . exec ( op ) ; final Subscription defaultSubscription = exec . subscribe ( x -> { } , mBakuContext :: onSyncError ) ; return withActivityLifecycle ( exec . doOnSubscribe ( defaultSubscription :: unsubscribe ) ) ; }
While the default implementation of {@link RxTable#exec(Func1)} provides an autoConnect
 observable that requires an explicit subscription, this implementation auto-subscribes the
 default Baku error handler and immediately begins the requested operation.
While the default implementation of { @link RxTable#exec ( Func1 ) } provides an autoConnect observable that requires an explicit subscription this implementation auto - subscribes the default Baku error handler and immediately begins the requested operation .
// TODO(rosswang): This is a bit fragile, as it can result in the default onSyncError being // called in (edge edge) cases where the async completes before ... wait a second, does the // above have to observeOn the main thread?