在 PureScript 中混合协程和 Websocket

Question

这是关于将 WebSocket 的输入和输出连接到协程的尝试。

以下函数接受 Connection，然后在收到消息时将其设置为 emit 协程值。

module Main where

import Prelude
import Control.Coroutine (emit, Producer, Consumer, await)
import Control.Monad.Eff (Eff)
import Control.Monad.Eff.Console (CONSOLE, log)
import Control.Monad.Eff.Var (($=))
import Control.Monad.Reader.Trans (lift)
import Control.Monad.Rec.Class (forever)
import WebSocket (WEBSOCKET, Connection(..), newWebSocket, URL(..), runMessage, runMessageEvent)

wsProducer :: Connection → Producer String (Eff _) Unit
wsProducer (Connection s) = s.onmessage $= emit <<< runMessage <<< runMessageEvent

Producer 和 Consumer 将连接到 Main（WebSocket 连接也将在那里建立），但尚未编写，因为上面的函数甚至不会类型检查。

请问如何进行类型检查？它不会进行类型检查的事实可能意味着上面的代码存在根本性的误解，如果是这样，用一个工作解决方案的代码示例进行解释将非常有帮助。

相关：this answer about Halogen and WebSockets 包含非常相似的代码。

Answer 1

这个 sn-p 有几个问题。首先，这是一个可行的版本：

module Main where

import Prelude

import Control.Coroutine (Producer)
import Control.Coroutine.Aff (produce)
import Control.Monad.Aff (Aff)
import Control.Monad.Aff.AVar (AVAR)
import Control.Monad.Eff.Var (($=))

import Data.Either (Either(..))

import WebSocket (WEBSOCKET, Connection(..), runMessageEvent, runMessage)

wsProducer :: forall eff. Connection → Producer String (Aff (avar :: AVAR, ws :: WEBSOCKET | eff)) Unit
wsProducer (Connection s) =
  produce \emit ->
    s.onmessage $= emit <<< Left <<< runMessage <<< runMessageEvent

1. 您错过了 produce 的使用，这是将 emit 纳入范围的原因，也是您制作制作人的方式。
2. 生产者必须使用Aff，而不是Eff。
3. emit 接受 Either - Left 值表示应生成值，Right 表示应关闭生产者。

看看at the docs for produce，希望你提到的误会能澄清！