如何在管道haskell内添加新源

Question

我在使用 network-conduit 时遇到以下代码问题：

import Data.Conduit.List as CL
import Data.Conduit.Text as CT
import qualified Data.ByteString.Char8 as S8
import qualified Data.Text as TT

mySource :: ResourceT m => Integer -> Source m Int
mySource i = {- function -} undefined

myApp :: Application
myApp src snk = 
    src $= CT.decode CT.ascii
        $= CL.map decimal
        $= CL.map {-problem here-}
        $$ src

在有问题的地方，我想写一些类似于

\t -> case t of
    Left err = S8.pack $ "Error:" ++ e
    Right (i,xs) = (>>>=) mySource 
                 {- or better: 
                   do 
                   (>>>=) mySource
                   (<<<=) T.pack xs
                  -}

(>>>=) 函数将 mySource 输出推到下一个级别的内容，并且 (<<<=) 正在将函数发送回上一级

Answer 1

网络将字节流分割成任意的ByteString块。通过上面的代码，这些 ByteString 块将被映射到 Text 块，并且每个 Text 块将被解析为 十进制。但是，表示单个小数的十进制数字字符串可以分为两个（或更多）Text块。此外，正如您所意识到的，使用十进制可以返回未解析为十进制部分的剩余文本块，您正试图将其推回到输入流中。

这两个问题都可以通过使用 Data.Conduit.Attoparsec 来解决。 PipelineParserEither 与 Data.Attoparsec.Text.decimal。请注意，仅解析十进制是不够的；您还需要处理小数点之间的某种分隔符。

也不可能从 CL.map 拼接 Source，因为 CL.map 的类型签名是

map :: Monad m => (a -> b) -> Conduit a m b

您传递给 < code>map 有机会将每个输入 a 转换为单个输出 b，而不是 b 的流。为此，您可以使用 awaitForever，但您需要使用 toProducer 将 Source 转换为通用 Producer code> 以使类型匹配。

但是，在您的代码中，您尝试将解析错误作为 ByteString 发送到下游，但将 mySource 的输出作为 Int 发送，这是一个类型错误。在这两种情况下，您都必须提供 ByteString 流；成功的解析案例可以返回一个通过融合其他 Conduit 而成的 Conduit，只要它最终得到 ByteString 的输出：

...
$= (let f (Left err) = yield $ S8.pack $ "Error: " ++ show err
        f (Right (_, i)) = toProducer (mySource i) $= someOtherConduit
    in awaitForever f)

其中 < code>someOtherConduit 从 mySource 接收 Int，并源 ByteString。

someOtherConduit :: Monad m => Conduit Int m ByteString

最后，我相信您的意思是连接管道末端的 snk 而不是 src。