fmt.

zio · Oct 21, 2020 · 7c9865e · 7c9865e
1 parent 9945c12
commit 7c9865e
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 9 deletions.
diff --git a/nio-core/src/main/scala/zio/nio/core/channels/SelectableChannel.scala b/nio-core/src/main/scala/zio/nio/core/channels/SelectableChannel.scala
@@ -134,8 +134,8 @@ final class ServerSocketChannel(override protected val channel: JServerSocketCha
   def accept: Managed[IOException, Option[SocketChannel]] =
     IO.effect(Option(channel.accept()).map(new SocketChannel(_)))
       .refineToOrDie[IOException]
-      .toManaged(IO.whenCase(_) {
-        case Some(channel) => channel.close.ignore
+      .toManaged(IO.whenCase(_) { case Some(channel) =>
+        channel.close.ignore
       })
 
   val localAddress: IO[IOException, SocketAddress] =

diff --git a/nio-core/src/main/scala/zio/nio/core/file/WatchService.scala b/nio-core/src/main/scala/zio/nio/core/file/WatchService.scala
@@ -76,8 +76,7 @@ final class WatchService private (private[file] val javaWatchService: JWatchServ
 
 object WatchService {
 
-  def forDefaultFileSystem: ZManaged[Blocking, IOException, WatchService] =
-    FileSystem.default.newWatchService
+  def forDefaultFileSystem: ZManaged[Blocking, IOException, WatchService] = FileSystem.default.newWatchService
 
   def fromJava(javaWatchService: JWatchService): WatchService = new WatchService(javaWatchService)
 }
diff --git a/nio-core/src/test/scala/zio/nio/core/channels/DatagramChannelSpec.scala b/nio-core/src/test/scala/zio/nio/core/channels/DatagramChannelSpec.scala
@@ -53,8 +53,7 @@ object DatagramChannelSpec extends BaseSpec {
         } yield assert(same)(isTrue)
       },
       testM("close channel unbind port") {
-        def client(address: SocketAddress): IO[IOException, Unit] =
-          DatagramChannel.open.use(_.connect(address).unit)
+        def client(address: SocketAddress): IO[IOException, Unit] = DatagramChannel.open.use(_.connect(address).unit)
 
         def server(
           address: SocketAddress,

diff --git a/nio-core/src/test/scala/zio/nio/core/channels/SelectorSpec.scala b/nio-core/src/test/scala/zio/nio/core/channels/SelectorSpec.scala
@@ -47,9 +47,8 @@ object SelectorSpec extends BaseSpec {
                                 for {
                                   scopeResult     <- scope(channel.accept)
                                   (_, maybeClient) = scopeResult
-                                  _               <- IO.whenCase(maybeClient) {
-                                                       case Some(client) =>
-                                                         client.configureBlocking(false) *> client.register(selector, Operation.Read)
+                                  _               <- IO.whenCase(maybeClient) { case Some(client) =>
+                                                       client.configureBlocking(false) *> client.register(selector, Operation.Read)
                                                      }
                                 } yield ()
                               case client: SocketChannel if readyOps(Operation.Read)          =>