conduit

2热度

1回答

我想使用管道从文件中读取数据，然后将数据流传输到标记器中。罪魁祸首是，即使是相同的字符序列可能会根据之前的输入产生不同的标记。那么我该如何处理State在一个Conduit之间的一堆IO？只要编写Conduit Char (State TokenizerStateType) Token确实会产生错误类型的几个错误（IO想要的状态有错误类型）。因为我不在我自己的电脑上，所以我不能提供一个不工作

8热度

1回答

如何制作“分支”导管？

我想同样的数据在两个“分支”来分别进行处理，然后选择“加入”分裂... +----------+ +---------+ -->| doublber |--- +--------+ +--------+ | |-- +----------+ -->| | +------+ | source |-->| splitter| | sum

1热度

2回答

将导管结合到普通功能中

我编写了一个简单的程序，在该程序中，我读取了一个大的XML文件，并对该文件的内容进行了一些处理，然后将处理后的数据保存在新文件中。原来的主要功能如下这样的事情： main = do content <- B.readFile "/home/sibi/github/data/chennai.osm" let tags = removeUnwanted $ parseTags

2热度

1回答

Conduit：提取随后的数字

我正在玩弄导管库，并且编写了一段代码来提取两个数字（2 & 3），当它们出现在一个序列中时。以下是我的代码： import Data.Conduit import qualified Data.Conduit.List as CL source = CL.sourceList [1,2,3,4,5,2,3] :: Source IO Int -- Extract the conseque

2热度

1回答

优化管道管道

我目前正在对我的程序进行基准测试，以查看我是否可以提高其性能。目前我的程序会接收一个输入文件并运行一些算法将其分成多个文件。将文件拆分为3部分大约需要14s，对于库和可执行文件都使用-O2编译标志。 ghc-options: -Wall -fno-warn-orphans -O2 -auto-all 看起来它会耗费其时间大约60％的sinkFile，我想知道是否有什么我可以做，以改善下面

3热度

1回答

conduit：只读源可能吗？

假设我有一个来源keypads :: Producer IO Keypad，它产生一个敏感数据流，例如一次性键盘。现在，如果我的库公开keypads，最终用户可能连接到keypads两个水槽，让我们称他们good和bad，其中bad请求的值，并读取它，但随后其返回上游通过leftover。稍后，good接收器可能会使用之前由bad读取的相同键盘。最终用户可能会忘记发生这种情况，例如，如果good

1热度

1回答

管道：</p> <pre><code>catsSource :: Source IO Category </code></pre> <p>下一步是写公司收集器（<code>Company</code>类型的项目）：从另一个来源

我有源抓取一些网站，并从中收集Category类型的项目做一个来源。公司收藏家需求类别：对于每个Category，投入几家公司应该逐一生产。换句话说，它应该“产生”Company，而不是[Company]。该任务需要什么？管道或棘手的来源？如果来源，它应该如何获得catsSource的类别？如果管道在发现时应该如何通过（“收益”）公司前进？要在这里清除我的问题是企图（不及格型检查）： impo

5热度

2回答

转换正常attoparsec解析器代码到管道/管

我一直在使用attoparsec写了以下分析代码： data Test = Test { a :: Int, b :: Int } deriving (Show) testParser :: Parser Test testParser = do a <- decimal tab b <- decimal return $

3热度

1回答

从文件无限读取

我正在尝试从文件读取一些不规则输入（例如，可能不时出现的命令）。例如。最初源文件是空的，并且我的程序已启动。然后一个字符串被追加到文件中，我的程序必须读取这个字符串。头一个幼稚的： import System.IO import Control.Monad listen :: Handle -> IO() listen file = forever $ do ineof <-

2热度

1回答

结合文件中的行与时间戳文件名

我有一个目录完整的CSV转储文件，我需要解析和处理。每个文件名都包含一个我知道如何提取的时间戳。然后我需要处理转储中的所有行，但是对于每一行我都需要知道它来自哪个文件时间戳。我可以分别获取时间戳，并且可以单独从文件中获取所有行（以下文件为How do I implement `cat` in Haskell?），但无法找到合并它们的方法。有任何想法吗？ {-# LANGUAGE Overloade