haskell-pipes

3열

2답변

Haskell Pipes - 파이프가 자체적으로 생산하는 것을 소비한다.

나는 파이프를 사용하여 웹 스크래퍼를 쓰려고하는데, 나는 긁힌 링크를 따라 갔다. URL을 다운로드하고, 링크를 찾아서 산출하는 process 함수가 있습니다. process :: Pipe Item Item (StateT CState IO)() .... for (each links) yield .... 이제이 링크를 반복적으로 따라 가서 S

5열

1답변

다중 사용자 네트워크 서버에 적합한 아키텍처입니까? (얼마나 많은 오버 헤드가 파이프 동시성을 도입합니까?)

나는 현재 상태 루프를 처리하는 하나의 스레드, 모든 상태 저장 논리를 처리하기위한 하나의 주 스레드, 연결된 클라이언트 당 2 개의 스레드를 갖기 위해 현재 가지고 있습니다. 하나의 클라이언트 스레드는 입력 파이프 라인을 처리하고 파이프 - 동시성을 사용하여 메시지를 기본 논리 스레드에 보냅니다. 다른 클라이언트 스레드는 출력 파이프 라인을 처리하여 메시

4열

2답변

에서 첫 번째 줄을 건너 뛰는 파이프 - attoparsec

내 유형 : data Test = Test { a :: Int, b :: Int } deriving (Show) 내 파서 :이 testParser :: Parser Test testParser = do a <- decimal tab b <- decimal return $ Test a b tab = char

1열

1답변

파이프에 Network.Socket.ByteString.recv가 발생합니다. (알 수없는 오류)

일을하는 어리석은 방법 일지 모르지만 여기에 설명되어 있습니다. 보내고받는 HTTP 요청을 응답 처리에서 분리하려고합니다. import Pipes import qualified Pipes.HTTP as HTTP import Pipes.Core import qualified Pipes.ByteString as PB import Network.Socke

6열

1답변

State with Pipes를 사용하는 방법?

유형이 Map Int String -> Proxy() a() Void IO b 인 함수가 있습니다. 지금은 await입니다. 그 값을 가지고 무엇이든하고 나서 다시 호출합니다. 그 대신 인수로 전달 된 State (Map Int String) 사용하도록 변경하고 싶습니다, 그래서 그냥 forever 사용할 수 있으며 모든 분기 recurse 기억할 필요가

5열

1답변

파이프와 비 파이프 코드 간의 동시성 고려 사항 코드

파이프 인터페이스에서 일부 인코딩을 위해 C 라이브러리를 래핑하는 과정에 있지만 설계 의사 결정을해야합니다. C 라이브러리가 설정된 후 엔코더 컨텍스트가 유지됩니다. 이를 통해 인코딩하거나 일부 매개 변수를 변경할 수 있습니다 (이 마지막 함수 인 Haskell 인터페이스를 tune :: Context -> Int -> IO()이라고 부름). 이 내 질문에

2열

1답변

Conduit을 사용하여 파일을 저장하는 방법은 무엇입니까?

콘딧의 라이브러리를 사용하여 파일을 어떻게 저장합니까? 이 의미는 변환 lines을 사용할 수 있도록 하는가 : main :: IO() main = do xxs <- lines <$> (readFile filePath) sourceList xxs =$ pipe $$ saveFile pipe :: Monad m => Conduit St

1열

1답변

하스켈에서 리소스를 즉시 닫는 방법은 무엇입니까?

낡은 pipestutorial은 다음과 같습니다. 이 코드는 버전 4.1.1에서 어떻게 보이나요? read' :: FilePath -> Frame Text IO C C() read' file = do liftU $ putStrLn "Opening file..." h <- liftU $ openFile file ReadMode

5열

1답변

파이프로 입력 끝을 감지하는 방법

파이프에서 최대 50 개의 항목 그룹을 읽고 IO 작업으로 처리하려고합니다. (이것에 대한 사용 사례는 데이터베이스에 데이터를 삽입하려고하는데, 훨씬 효율적이기 때문에 전체 트랜잭션을 하나의 트랜잭션 내에서 수행하려고합니다.) 여기에 지금까지있어 무엇의 단순화 된 버전입니다 : 삽입 할 항목의 수 (50)에 의해 분할 발생하지 않는 한 문제는, 내가 그리워

5열

2답변

haskell pipes-bytestring을 사용하여 행 단위로 파일 반복 수행

파이프 라이브러리를 사용하고 있으며 ASCII 인코딩을 사용하여 ByteString 스트림을 행 스트림 (즉, String)으로 변환해야합니다. 아마도 다른 라이브러리 (Pipes.Text 및 Pipes.Prelude)를 사용하여 텍스트 파일에서 선을 더 쉽게 얻을 수 있다는 것을 알고 있지만 다른 코드로 인해 Producer에서 String이라는 줄을 가