diff --git a/core/src/main/java/com/softwaremill/jox/CloseableChannel.java b/core/src/main/java/com/softwaremill/jox/CloseableChannel.java index d0bfe28..6f1f34f 100644 --- a/core/src/main/java/com/softwaremill/jox/CloseableChannel.java +++ b/core/src/main/java/com/softwaremill/jox/CloseableChannel.java @@ -14,7 +14,7 @@ *
* Closing the channel is thread-safe. */ -public interface CloseableChannel extends AutoCloseable { +public interface CloseableChannel { /** * Close the channel, indicating that no more elements will be sent. *
@@ -40,15 +40,6 @@ public interface CloseableChannel extends AutoCloseable { */ Object doneSafe(); - /** - * Same as {@link #done()}: close the channel, indicating that no more elements will be sent. - *
- * Enables using channel in {@code try-with-resources} blocks. - */ - default void close() { - done(); - } - // /** diff --git a/core/src/main/java/com/softwaremill/jox/CollectSource.java b/core/src/main/java/com/softwaremill/jox/CollectSource.java index 81abd74..69b920f 100644 --- a/core/src/main/java/com/softwaremill/jox/CollectSource.java +++ b/core/src/main/java/com/softwaremill/jox/CollectSource.java @@ -117,11 +117,6 @@ public Object doneSafe() { return original.doneSafe(); } - @Override - public void close() { - original.close(); - } - @Override public void error(Throwable reason) { original.error(reason);