docs: public static <T> Connectable<T> schedule(final Stream<T> stream, final String cron, final ScheduledExecutorService ex) {
          return new NonPausableConnectable<>(
                                            stream).schedule(cron, ex);
      }