docs: public static <T> Connectable<T> scheduleFixedRate(final Stream<T> stream, final long rate, final ScheduledExecutorService ex) {
          return new NonPausableConnectable<>(
                                            stream).scheduleFixedRate(rate, ex);
      }