conduit

5熱

1答えて

タイトルはそれをすべて言います。いくつかの人々が同一性コンジットとしてData.Conduit.List.map idを使用していることがわかりましたが、これはデータを変更しないでストリームするための推奨方法ですか？

5熱

1答えて

コーパス内のNGramの頻度を数えるプログラムを書く。どうすればよい tokens --- trigrams --- countFreq ：私はちょうど1つのストリームの消費者は、ストリームソースに接続することができます現時点で ngram :: Monad m => Int -> Conduit t m [t] trigrams = ngram 3 countFreq :: (Ord t

1熱

1答えて

コンジットをExceptTに入れよう

ExceptTにコンジットをラップする良い方法はありますか？このアプローチでは、エラーが発生したときに処理を停止し、エラーメッセージを抽出する必要があります。ここではおもちゃのコードは、エラー処理なしである - それはただ静かに停止します。 import Data.Conduit as C import Data.ByteString as BS import Control.Monad i

7熱

4答えて

コンジットとソケット：複数の接続を許可

conduit、network-conduit、およびstm-conduitを使用して、小さな受信サーバーを実装するコードを次に示します。ソケット上のデータを受信し、STMチャネルを介してメインスレッドにストリームします。 import Control.Concurrent (forkIO) import Control.Concurrent.STM (atomically) import C

0熱

1答えて

保管トラック<code>Network.HTTP.Conduit</code>でrequestBodySourceIO

を使用して、requestBodySourceIOこの型シグネチャを有する： Prelude Network.HTTP.Conduit Data.Conduit Control.Monad.Trans.Resource> :t requestBodySourceIO requestBodySourceIO :: GHC.Int.Int64 -> Source IO Data.

1熱

1答えて

は、彼らが明示的<code>Monad</code>のインスタンスでないときは、別のものに1 <code>ResumableSource</code>を追加するにはどうすればよい別の

に1 ResumableSourceを追加は？ここでは下記のおもちゃの一例である - bがそれを持っていませんがaはMonad制約があります。だから我々はa'sなくb'sを追加することができます Prelude> import Data.Conduit Prelude Data.Conduit> import Data.ByteString as BS Prelude Data.Conduit

0熱

1答えて

厳密なバイトコードのための導管の効率的チャンク化

これはこのearlier questionのフォローアップです。私はコンジットソース（Network.HTTP.Conduit）を持っています。これは厳密にはByteStringです。私はそれらをより大きなチャンクに再結合したい（別のエンコーディングとレイジーなバイトストリングへの変換の後、ネットワークを介して別のクライアントに送信する）。私はchunksOfAtLeastコンジットを書きました、

5熱

3答えて

Haskellのzip-conduitを使用してzipアーカイブ内のファイルから行を読み取る

タイトルによれば、zipアーカイブ内にあるファイルからzip-conduit（zipファイル私は扱っている非常に大きい、私は定数メモリでこれを行うことができる必要があります）。私は導管の基本的なアイデアを突き詰めましたが、怒りの中でそれらを使ったことは一度もなく、どこから始めるべきかについて非常に固執しています。私はコンジットチュートリアルを読んだことがありますが、私はそれを自分の問題と一致させる

10熱

1答えて

Windows 8で「InternalIOException getAddrInfo：存在しません（エラー10093）」

このような単純なコードが機能しないのはなぜですか？ import Network.HTTP.Conduit import qualified Data.ByteString.Lazy as L main :: IO() main = simpleHttp "http://www.dir.bg/" >>= L.putStr それは、次のエラーが発生： TestConduit.exe: I

1熱

1答えて

ストリームに間違った長さを送信すると、HTTPマネージャの共有状態が破損する

共有HTTPマネージャを指定すると、requestBodySourceのrequestBodyで、長さが間違っていると、後続の要求が同じHTTPマネージャーに約20秒間。おそらくこの問題の原因となっている共有状態とGivesPopperの相互作用についての何かがあるようです。ここでは、それを再現するサンプルコードです - 私たちは間違った長さのアップロードを送信するためにrequestb.inを使