negate rtn value

armanbilge · Aug 25, 2023 · b075456 · b075456
1 parent 7bb8985
commit b075456
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/uring/src/main/scala/fs2/io/uring/Uring.scala b/uring/src/main/scala/fs2/io/uring/Uring.scala
@@ -64,13 +64,13 @@ private[uring] final class Uring[F[_]](ring: UringExecutorScheduler)(implicit F:
                     G.unit,
                     // if cannot cancel, fallback to get
                     get.flatMap { rtn =>
-                      if (rtn < 0 && !mask(rtn)) G.raiseError(IOExceptionHelper(-rtn))
+                      if (rtn < 0 && !mask(-rtn)) G.raiseError(IOExceptionHelper(-rtn))
                       else lift(release(rtn))
                     }
                   )
                 )
               }
-              .flatTap(e => G.raiseWhen(e < 0 && !mask(e))(IOExceptionHelper(-e)))
+              .flatTap(e => G.raiseWhen(e < 0 && !mask(-e))(IOExceptionHelper(-e)))
           }
         }
       }