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