fix unhandled errors in fiber for ZIO2

Author: keisar

zio2-zmq/src/main/scala/zio/zmq/ZSocket.scala

@@ -93,18 +93,20 @@ class ZSocket private (
         }
         .refineToOrDie[ZMQException]
 
-      msg <-
-        if (msg != null) ZIO.succeed(msg)
-        else
-          ZIO
-            .attemptBlockingCancelable {
-              val msg = socket.recv(0, canceled)
-              if (msg != null) msg
-              else throw new ZMQException(socket.errno())
-            }(ZIO.attempt(socket.cancel(canceled)).orDie)
-            .refineToOrDie[ZMQException]
-            .retryWhile(_.getErrorCode() == ZmqError.EAGAIN)
-    } yield msg
+      msg <- if (msg != null) ZIO.succeed(msg)
+                  else {
+                    zio
+                      .ZIO
+                      .attemptBlockingCancelable {
+                        val msg = socket.recv(0, canceled)
+                        if (msg != null) Right(msg)
+                        else Left(new ZMQException(socket.errno()))
+                      }(ZIO.attempt(socket.cancel(canceled)).orDie)
+                      .absolve
+                      .refineToOrDie[ZMQException]
+                      .retryWhile(_.getErrorCode() == ZmqError.EAGAIN)
+                  }
+          } yield msg
 
   def receiveMsg: ZIO[Any, ZMQException, Msg] = receiveMsgWait(
     new AtomicBoolean(false)