baku-toolkit/lib/src/main/java/io/v/rx/syncbase/RxTable.java
/**
     * Creates an autoConnect observable that performs the given operation upon subscription (once
     * a Syncbase client is available).
     */
Creates an autoConnect observable that performs the given operation upon subscription (once
a Syncbase client is available).
Creates an autoConnect observable that performs the given operation upon subscription ( once a Syncbase client is available ) .
public <T> Observable<T> exec(final Func1<Table, ListenableFuture<T>> op) {
        return once()
                .flatMap(t -> toObservable(op.call(t)))
                .replay(1).autoConnect();
    }
public < T > Observable < T > exec ( final Func1 < Table , ListenableFuture < T > > op ) { return once ( ) . flatMap ( t -> toObservable ( op . call ( t ) ) ) . replay ( 1 ) . autoConnect ( ) ; }
Creates an autoConnect observable that performs the given operation upon subscription (once
 a Syncbase client is available).
Creates an autoConnect observable that performs the given operation upon subscription ( once a Syncbase client is available ) .