scala - MVar tryPut返回true，isEmpty也返回true

我写了一个简单的callback(handler)函数，该函数传递给异步api，我想等待结果:

object Handlers {

  val logger: Logger = Logger("Handlers")
  implicit val cs: ContextShift[IO] =
  IO.contextShift(ExecutionContext.Implicits.global)

  class DefaultHandler[A] {

  val response: IO[MVar[IO, A]] = MVar.empty[IO, A]

  def onResult(obj: Any): Unit = {
    obj match {
      case obj: A =>
        println(response.flatMap(_.tryPut(obj)).unsafeRunSync())
        println(response.flatMap(_.isEmpty).unsafeRunSync())
      case _ => logger.error("Wrong expected type")
    }
  }

  def getResponse: A = {
    response.flatMap(_.take).unsafeRunSync()
  }
}

但是由于某些原因，tryPut和isEmpty(当我手动调用onResult方法时)都返回true，因此，当我调用getResponse时，它将永远休眠。
这是我的测试:

class HandlersTest extends FunSuite {
    test("DefaultHandler.test") {
    val handler = new DefaultHandler[Int]
    handler.onResult(3)
    val response = handler.getResponse
    assert(response != 0)
    }
  }

有人可以解释为什么tryPut返回true，但是什么也没放。在Scala中使用Mvar /通道的正确方法是什么？

最佳答案

IO[X]意味着您具有创建一些 X 的秘诀。因此，在您的示例中，yuo正在输入一个 MVar ，然后再输入另一个。

这就是我要怎么做。

object Handlers {
  trait DefaultHandler[A] {
    def onResult(obj: Any): IO[Unit]

    def getResponse: IO[A]
  }

  object DefaultHandler {
    def apply[A : ClassTag]: IO[DefaultHandler[A]] =
      MVar.empty[IO, A].map { response =>
        new DefaultHandler[A] {
          override def onResult(obj: Any): IO[Unit] = obj match {
              case obj: A =>
                for {
                  r1 <- response.tryPut(obj)
                  _  <- IO(println(r1))
                  r2 <- response.isEmpty
                  _  <- IO(println(r2))
                } yield ()

              case _ =>
                IO(logger.error("Wrong expected type"))
            }

          override def getResponse: IO[A] =
            response.take
        }
      }
  }
}

关于scala - MVar tryPut返回true，isEmpty也返回true，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/59535302/