code: public static <T> Publisher<T> publisher(Observable<T> observable) {
          return observable.toFlowable(BackpressureStrategy.BUFFER);
      }
docs: Convert an Observable to a reactive-streams Publisher
  
  @param observable To convert
  @return reactive-streams Publisher