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 .