Я хочу сериализовать входящие значения в JSON. Каждое значение имеет экземпляр toJSON . Конечным результатом должен быть список. Текущий код следующий: import Pipes import qualified Pipes.Prelude as P -- assume a source of elements main :: IO...

Предыстория У меня есть несколько файлов данных, каждый из которых содержит список записей данных (по одному на строку). Подобно CSV, но достаточно отличается, чтобы я предпочел написать свой собственный анализатор, а не использовать библиотеку...

Допустим, у меня есть два Proxy в Haskell Pipes. Они представляют внешние системные процессы. produce :: MonadIO m => Producer ByteString m ExitCode consume :: MonadIO m => Consumer ByteString m ExitCode Поэтому я подключаю их к...

Я пытаюсь понять разницу между каналом и трубами . В отличие от каналов , кондуит имеет понятие остатков. Чем полезны остатки? Я хотел бы увидеть несколько примеров, когда остатки необходимы. А поскольку в трубах нет концепции остатков,...

Я пытаюсь понять различия между различными реализациями концепции каналов. Одно из различий между каналом и трубами заключается в том, как они соединяют трубы вместе. Канал имеет (>+>) :: Monad m => Pipe l a b r0 m r1 ->...

Я хочу создать процесс и периодически записывать текст из моей программы haskell в стандартный ввод процесса (из действия ввода-вывода). Следующее правильно работает в GHCi, но не работает правильно при сборке и запуске. В GHCi все работает...

Мне трудно написать pipe с этой подписью: toOneBigList :: (Monad m, Proxy p) => () -> Pipe p a [a] m r Он должен просто взять все a из восходящего потока и отправить их в виде списка вниз по течению. Все мои попытки выглядят...

У меня есть функция типа Map Int String -> Proxy () a () Void IO b . Прямо сейчас он await s делает все, что угодно, с полученным значением, а затем повторно вызывает себя. Я хотел бы изменить его так, чтобы он использовал State (Map Int...

В учебнике по каналам , там написано что: Синонимы конкретного типа используют () для закрытия неиспользуемых входов и X (необитаемый тип) для закрытия неиспользуемых выходов: Я хотел бы понять, почему () и X используются именно...

У меня есть код, который использует дескриптор файла для имитации приемника потоковой передачи Bytestring из источника ( AWS S3 ). Если мы хотим использовать Network.Websocket в качестве приемника , достаточно ли заменить LBS.writeFile в...

Это тесно связано с ответом Габриэля на другой вопрос . Я написал функцию, которая предоставляет что-то вроде функции ||| из ArrowChoice , но для Proxy (из библиотеки pipes ). Он соответствует шаблону и имеет пять взаимно рекурсивных функций....

Я закончил читать руководство по каналам и Я хотел написать функцию для рекурсивного перечисления всех файлов в каталоге. Я пробовал со следующим кодом: enumFiles :: FilePath -> Producer' FilePath (PS.SafeT IO) () enumFiles path =...

Контекст : я реализую приложение в CQRS и пытаюсь оптимизировать обработку команд (в основном 1 поток по совокупному идентификатору)... Проблема : я хотел бы иметь первый поток, который получает все команды и отправляет их по их совокупному...

Я могу заставить подписчика ZMQ работать в Haskell, но был бы признателен за руководство о том, как использовать эти данные с Pipes. Моя попытка написать Producer терпит неудачу при «сборке стека» со следующей ошибкой: Не удалось сопоставить тип...