code: public static <T> Observable<T> observable(Publisher<T> publisher) {
          return Flowable.fromPublisher(publisher).toObservable();
      }
docs: Convert a Publisher to an observable
  
  @param publisher To convert
  @return Observable