List<String> extendedUrlList = new ArrayList<>(urlList);
 extendedUrlList.add(null);
 ...
+.filter(Objects::nonNull)
 .map(Item::getPubDateZonedDateTime)
 

 public void forEach(Consumer<? super T> action) {
     autoClose(stream -> {
-        stream.forEach(action);
+        try {
+            stream.forEach(action);
+        } catch (Exception e) {
+            stream.close();
+            throw e;
+        }
         return null;
     });
 }
 

 var timestamps = new RssReader().read(extendedUrlList)
-                .sorted()
+                .sorted(Comparator.comparing(item -> item.getPubDateZonedDateTime().orElse(null)))
                 .map(Item::getPubDateZonedDateTime)
                 .flatMap(Optional::stream)
                 .map(t -> t.toInstant().toEpochMilli())
                 .collect(Collectors.toList());
 

+assertNotNull(timestamps);
+assertFalse(timestamps.isEmpty());
 assertTrue(timestamps.size() > 200);
 

 public Stream<T> onClose(Runnable closeHandler) {
-    return asAutoCloseStream(stream().onClose(closeHandler));
+    return asAutoCloseStream(stream().onClose(() -> {
+        try {
+            closeHandler.run();
+        } finally {
+            super.onClose(closeHandler);
+        }
+    }));
 }
 

-if (LOGGER.isLoggable(Level.WARNING)) {
-    LOGGER.log(Level.WARNING, () -> String.format("Failed read URL %s. Message: %s", url, e.getMessage()));
-}
+Optional.ofNullable(LOGGER)
+    .filter(logger -> logger.isLoggable(Level.WARNING))
+    .ifPresent(logger -> logger.log(Level.WARNING, () -> String.format("Failed read URL %s. Message: %s", url, e.getMessage())));
 

+@Override
 public Stream<T> parallel() {
+    super.parallel();
     return asAutoCloseStream(stream().parallel());
 }
+@Override
 public Stream<T> sequential() {
+    super.sequential();
     return asAutoCloseStream(stream().sequential());
 

-} catch (XMLStreamException | IOException e) {
-    if (LOGGER.isLoggable(Level.WARNING)) {
-        LOGGER.log(Level.WARNING, "Failed to close XML stream. ", e);
-    }
+} catch (XMLStreamException e) {
+    LOGGER.log(Level.SEVERE, "Error closing XML stream", e);
+} catch (IOException e) {
+    LOGGER.log(Level.SEVERE, "IO error when closing stream", e);
 }
 

 return AutoCloseStream.of(urls.stream()
     ...
     return Stream.empty();
-}));
+}).onClose(() -> {
+    // Ensure all resources are closed properly here
+});
 

 public Iterator<T> iterator() {
-    return stream().iterator();
+    throw new UnsupportedOperationException("Auto-closing iterator is not supported.");
 }
 public Spliterator<T> spliterator() {
-    return stream().spliterator();
+    throw new UnsupportedOperationException("Auto-closing spliterator is not supported.");
 }
 

-var timestamps = new RssReader().read(extendedUrlList)
+List<Long> timestamps = new RssReader().read(extendedUrlList)
                 ...
                 .collect(Collectors.toList());