static <T> Observable<T> wrap(
            ObservableSource<T> source, Collection<ReactiveInstrumenter> instrumentations) {
        if (source instanceof Callable) {
            return new RxInstrumentedCallableObservable<>(source, instrumentations);
        }
        return new RxInstrumentedObservable<>(source, instrumentations);
    }
static < T > Observable < T > wrap ( ObservableSource < T > source , Collection < ReactiveInstrumenter > instrumentations ) { if ( source instanceof Callable ) { return new RxInstrumentedCallableObservable < > ( source , instrumentations ) ; } return new RxInstrumentedObservable < > ( source , instrumentations ) ; }
Wrap a observable.
@param source The source
@param instrumentations The instrumentations
@param <T> The type
@return The wrapped subscriber