conduit icon indicating copy to clipboard operation
conduit copied to clipboard

A streaming data library

Results 46 conduit issues
Sort by recently updated
recently updated
newest added

I was using MonadUnliftIO so I could easily parallelise functions by running them in multiple threads, but after a refactoring to use more parallelism I've started noticing some errors from...

As a conduit **and** haskell newbie, I'm having problems understanding how conduit should be used processing text file one line at a time. I'm going to list the things that...

So, I admit I haven't looked at the code of `process` and the GHC runtime enough to be sure, but as far as I can tell `withCheckedProcessCleanup` calls `terminateProcess` to...

I'm not sure if this is a bug or just undocumented behaviour, but the following will raise an exception: CP.sourceProcessWithStreams (proc "false" []) (CC.yieldMany ["Hello", "World"]) CL.consume CL.consume See full...

Hi, I have a situation like the one outlined in the image below, where my producer feeds Products to a function that queries a database for some information about them....

I often use conduit for converting paginated systems into providing a flat stream of elements. Typically I need to get the last element of a page and pull the appropriate...

Here's an interesting space leak that we have discovered after switching to `lts-11` (and `conduit-1.3`). ### Background We have a sync job that requests a big XML file over HTTP,...

It seems the variety of I/O functions exposed is a little ad-hoc. Consider sinkHandle, it has an IO variant, a cautious variant, a Builder variant, a Flush variant, but only...

I have been struggling with why conduit performance results are out of the whack in these benchmarks https://github.com/composewell/streaming-benchmarks. I have root caused the issue to `mapM_` to discard the stream....

I wrote an application based on https://github.com/snoyberg/conduit/blob/829195895420b90dc7daa393d4178da4141e22ed/PROCESS.md and `conduit-extra-1.2.3.2`. It talks to `ghci`, submitting it input commands like `:reload`. If found it not to work: With `input` looking like this:...