code: public static <T> Connectable<T> scheduleFixedRate(final Stream<T> stream, final long rate, final ScheduledExecutorService ex) {
          return new NonPausableConnectable<>(
                                            stream).scheduleFixedRate(rate, ex);
      }
docs: Execute this Stream on a schedule
  
  <pre>
  {@code
  //run every 60 seconds
  Streams.scheduleFixedRate(Stream.generate(()->"next job:"+formatDate(new Date()))
  .map(this::processJob),
  60_000,Executors.newScheduledThreadPool(1)));
  }
  </pre>
  
  Connect to the Scheduled Stream
  
  <pre>
  {@code
  Connectable<Data> dataStream = Streams.scheduleFixedRate(Stream.generate(()->"next job:"+formatDate(new Date()))
  .map(this::processJob)
  ,60_000,Executors.newScheduledThreadPool(1)));
  
  
  data.connect().forEach(this::logToDB);
  }
  </pre>
  @param stream the stream to schedule element processing on
  @param rate Time in millis between job runs
  @param ex ScheduledExecutorService
  @return Connectable Connectable of emitted from scheduled Stream