baku-toolkit/lib/src/main/java/io/v/rx/syncbase/SgHostUtil.java
/**
     * @return an observable that emits an item when a Syncbase instance is known to be hosted at
     * the given name. The mount is updated for any new server instances until this observable has
     * been unsubscribed.
     */
@return an observable that emits an item when a Syncbase instance is known to be hosted at
the given name. The mount is updated for any new server instances until this observable has
been unsubscribed.
@return an observable that emits an item when a Syncbase instance is known to be hosted at the given name . The mount is updated for any new server instances until this observable has been unsubscribed .
public static Observable<Object> ensureSyncgroupHost(
            final VContext vContext, final Observable<Server> rxServer, final String name) {
        return rxServer.switchMap(s -> isSyncbaseOnline(vContext, name)
                .flatMap(online -> online ? Observable.just(0) : mountSgHost(rxServer, name)));
    }
public static Observable < Object > ensureSyncgroupHost ( final VContext vContext , final Observable < Server > rxServer , final String name ) { return rxServer . switchMap ( s -> isSyncbaseOnline ( vContext , name ) . flatMap ( online -> online ? Observable . just ( 0 ) : mountSgHost ( rxServer , name ) ) ) ; }
@return an observable that emits an item when a Syncbase instance is known to be hosted at
 the given name.
@return an observable that emits an item when a Syncbase instance is known to be hosted at the given name .