为什么使用网络管道时await总是返回Nothing ?

Question

我正在学习如何使用导管。我有一个管道，它接受字节串并将它们分组成表示发送到服务器的操作的数据包。然后我有一个管道接收这些数据包，对它们进行操作并产生响应数据包。最后，我有一个管道，它接收响应数据包并将它们转换为字节串流。问题是在包处理管道中的yield总是返回Nothing。我的代码看起来像这样

processingConduit :: ServerState -> Conduit BS.ByteString IO BS.ByteString
processingConduit state = getPacketConduit
    =$= processPacketConduit state
    =$= putPacketConduit
processPacketConduit :: ServerState -> Conduit ClientPacket IO ServerPacket
processPacketConduit state = awaitForever $ packet -> do
    liftIO $ putStrLn "got something :)"
    let function = case packet of
            (LoginPacket _ _) -> login
            _                 -> ugh
    result <- liftIO $ function state packet
    yield result
getPacketConduit :: Conduit BS.ByteString IO ClientPacket
getPacketConduit = conduitGet (get :: Get ClientPacket)
putPacketConduit :: Conduit ServerPacket IO BS.ByteString
putPacketConduit = conduitPut (put :: ServerPacket -> Put)

我使用runTCPServer运行管道，它能够接受连接，getPacketConduit能够将字节串转换为有效的数据包，但是awaitForever永远不会调用它的函数。如果我修改processPacketConduit来使用await，我可以看到它总是返回Nothing。

Answer 1

我发现了我的错误，我忘记了谷类通过发送length:: Int和实际数据来序列化bytestring。我只发送了一个字节的长度