Это кажется разумным желанием, но у меня проблемы с типом. Я хотел бы иметь Client , который может отправить список параметров Server , который выберет один и вернет выбранный элемент. Что-то вроде этого: module Toy where import Pipes asker...

Мне нужно составить потребитель и трубу так, чтобы выход потребителя питал вход трубы. Я думаю, это можно решить с помощью комбинатора, подобного этому: Consumer i m r -> (r -> Producer o m r') -> Pipe i o m r' или это:...

Учитывая простой пример типа JSON: data Test = Test { name :: Text , age :: Int } deriving (Show, Generic) instance FromJSON Test Как я могу использовать pipe-ason для декодирования потока сообщений JSON, поступающих через сокет,...

Вопрос как запустить Consumer внутри Pipe уже задан, но ответ, который был предложен тогда, требует синонима полиморфного типа Consumer' : {-# LANGUAGE RankNTypes #-} import Pipes toPipe :: Monad m => Consumer' i m o -> Pipe i o m...

На Reddit есть заархивированная ветка, в которой говорится, что, по сути, трубопровод / трубы не могут быть стрелками, потому что стрелки должны быть синхронными. Ветка связана здесь...

Я пытаюсь понять один из примеров, представленных на руководство по каналам относительно ListT : import Pipes import qualified Pipes.Prelude as P input :: Producer String IO () input = P.stdinLn >-> P.takeWhile (/= "quit") name :: ListT...

Я пытаюсь еще больше оптимизировать парсер и хранилище pipe-attoparsec, но у меня возникают проблемы с уменьшением использования памяти. Данный аккаунт-parser.hs {-# LANGUAGE RankNTypes #-} {-# LANGUAGE OverloadedStrings #-} {-# LANGUAGE...

Мотивация этого вопроса заключается в следующем сценарии: у нас есть поток значений, которые представлены кодировкой Sum . Предположим, что Either ByteString ByteString , где мы представляем потоки байтов в ошибочных и хороших состояниях...

Предполагается, что функция withTimeout передает ConsoleEvent сообщение CeTimeout каждые s :: Int секунды, если ничего не было получено. Вместо этого ему не удается отправить события CeTimeout в нужное время. Одно событие CeTimeout...