내가 파이프를 사용하는 일부 하스켈 코드를 가지고 : module Main(main) where
import Pipes
a :: Producer Int IO()
a = each [1..10]
b :: Pipe Int Int IO()
b = do
x <- await
yield (x*2)
b
c :: Consumer
기본적으로 도관/파이프는 화살표가 될 수 없다는 reddit의 아카이브 된 스레드가 있습니다. b/c 화살표는 동기가되어야합니다. 스레드가 여기에 링크되어 있습니다. https://www.reddit.com/r/haskell/comments/rq1q5/conduitssinks_and_refactoring_arrows/ "동기식"이 화살표 정의의 일부가 아닌
TLS 연결을 사용하여 응답 본문을 얻으려면 http-client 자습서를 사용하고 있습니다. withResponse에 의해 print이 호출됨을 알 수 있기 때문에, 왜 print은 다음과 같은 결과물에 전체 응답을 보내지 않습니까? withResponse request manager $ \response -> do
putStrLn $ "The
저는 파이프 생태계와 파이프 동시성을 가진 스트리밍 기능을 작성하고 있습니다.이 기능은 작동 라이브러리를 기반으로하여 제가 산출하는 작은 프로그램 조각을 빨리 만들 수있게합니다 네트워크를 통해 서버에 명령을 보내거나 쉘 명령에서 stdin/out 명령을 실행 한 다음 응답을 다시 읽습니다. 이 경우에는 별표이지만 비슷한 것으로 일반화 될 수 있습니다. 처음
파일을 한 번에 하나씩 가져 와서 전체 파일을 메모리에로드하지 않고 쉬운 방법이 있는지 궁금합니다. 나는 attoparsec 파서로 줄을 넘기고 싶다. 나는 hGetLine와 함께 Data.Text.Lazy.IO을 사용해 보았는데 그것은 내 기억을 통해 불어났다. 나는 나중에 전체 파일을로드합니다. s <- Pipes.sum $
folds (\i
의 내용에 따라 파일을 열 : import Pipes
import Pipes.Safe
import qualified Pipes.Prelude as P
import qualified Pipes.Safe.Prelude as P
import System.IO
import Data.Text as T
import Data.Text.IO as TIO
i
나는 이것을 Haskell과 파이프 라이브러리의 초보자라고 말하고, 무엇이 test 함수에서이 프로그램의 높은 메모리 사용을 일으키는 지 알고 싶다. . deepseq 사용하지 않는 특히 내가 최종 결과까지 데 MyRecord 값의 축적을보고 있어요 test에 r1 값을 생성하는 배에서 이 생산된다. ~ 500000 줄/230 MB의 샘플 데이터 세트에서
튜토리얼 https://hackage.haskell.org/package/pipes-attoparsec-0.1.0.1/docs/Control-Proxy-Attoparsec-Tutorial.html을 따라 attoparsec과 함께 파이프를 사용하는 방법을 배우려고합니다. 하지만 Control.Proxy.Trans.Either를 가져올 수 없습니다. lib에
나는 pipes-csv 라이브러리로 csv 파일을 읽습니다. 나는 첫번째 줄을 읽고 나중에 나머지를 읽고 싶다. 불행히도 Pipes.Prelude.head 함수가 반환됩니다. 파이프가 어떻게 든 닫혀 있습니다. csv의 헤드를 먼저 읽고 나중에 나머지를 읽는 방법이 있습니까? 우리가 먼저 헤더를 읽을 수없는 경우 import qualified Data.Ve