baku-toolkit/lib/src/main/java/io/v/rx/syncbase/RxTable.java
/**
     * Watches a specific Syncbase row for changes.
     */
Watches a specific Syncbase row for changes.
Watches a specific Syncbase row for changes .
public <T> Observable<SingleWatchEvent<T>> watch(final String key, final TypeToken<T> tt,
                                                     final T defaultValue) {
        return this.<SingleWatchEvent<T>>watch((db, s) ->
                subscribeWatch(s, db, key, tt, defaultValue))
                .replay(1)
                .refCount();
    }
public < T > Observable < SingleWatchEvent < T > > watch ( final String key , final TypeToken < T > tt , final T defaultValue ) { return this . < SingleWatchEvent < T > > watch ( ( db , s ) -> subscribeWatch ( s , db , key , tt , defaultValue ) ) . replay ( 1 ) . refCount ( ) ; }
Watches a specific Syncbase row for changes.
Watches a specific Syncbase row for changes .
// Don't create new watch streams for subsequent subscribers, but do cancel the // stream if no subscribers are listening (and restart if new subscriptions happen).