Merge pull request #2582 from armanbilge/topic/ClosedChannelException

Introduce `fs2.io.ClosedChannelException`
typelevel · Sep 10, 2021 · f537af0 · f537af0
2 parents 91938ac + 00d15b9
commit f537af0
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 8 deletions.
diff --git a/io/js/src/main/scala/fs2/io/IOException.scala b/io/js/src/main/scala/fs2/io/IOException.scala
@@ -38,3 +38,5 @@ object IOException {
       .orElse(FileSystemException.unapply(cause))
       .orElse(UnknownHostException.unapply(cause))
 }
+
+class ClosedChannelException extends IOException
diff --git a/io/jvm/src/main/scala/fs2/io/ioplatform.scala b/io/jvm/src/main/scala/fs2/io/ioplatform.scala
@@ -31,6 +31,7 @@ import fs2.io.internal.PipedStreamBuffer
 import java.io.{InputStream, OutputStream}
 
 private[fs2] trait ioplatform {
+  type ClosedChannelException = java.nio.channels.ClosedChannelException
 
   /** Pipe that converts a stream of bytes to a stream that will emit a single `java.io.InputStream`,
     * that is closed whenever the resulting stream terminates.

diff --git a/io/jvm/src/main/scala/fs2/io/net/AsynchronousDatagramSocketGroup.scala b/io/jvm/src/main/scala/fs2/io/net/AsynchronousDatagramSocketGroup.scala
@@ -25,13 +25,7 @@ package net
 
 import java.net.InetSocketAddress
 import java.nio.{Buffer, ByteBuffer}
-import java.nio.channels.{
-  CancelledKeyException,
-  ClosedChannelException,
-  DatagramChannel,
-  SelectionKey,
-  Selector
-}
+import java.nio.channels.{CancelledKeyException, DatagramChannel, SelectionKey, Selector}
 import java.util.ArrayDeque
 import java.util.concurrent.{ConcurrentLinkedQueue, CountDownLatch}
 import java.util.concurrent.atomic.AtomicLong

diff --git a/io/jvm/src/main/scala/fs2/io/net/DatagramSocketGroupPlatform.scala b/io/jvm/src/main/scala/fs2/io/net/DatagramSocketGroupPlatform.scala
@@ -24,7 +24,7 @@ package io
 package net
 
 import java.net.{InetSocketAddress, NetworkInterface}
-import java.nio.channels.{ClosedChannelException, DatagramChannel}
+import java.nio.channels.DatagramChannel
 
 import cats.effect.kernel.{Async, Resource}
 import cats.syntax.all._