code: public static <T> Function<Stream<Timed<T>>, Stream<Stream<Timed<T>>>> window(final Duration duration, final LongSupplier startTime) {
          return window(duration, duration.toMillis(), startTime);
      }
docs: Split this stream by the specified duration.
  
  <pre>
  <code>
  Stream<Timed<MyObject>> s = ...;
  s.__(Fn.window(Duration.ofMinutes(3), () - System.currentTimeMillis()))...// Do your stuffs with Stream<Stream<Timed<T>>>;
  </code>
  </pre>
  
  @param duration
  @param startTime
  @return