Почему Conduit и Pipe не могут иметь экземпляр Arrow?

На Reddit есть заархивированная ветка, в которой говорится, что, по сути, трубопровод / трубы не могут быть стрелками, потому что стрелки должны быть синхронными. Ветка связана здесь https://www.reddit.com/r/haskell/comments/rq1q5/conduitssinks_and_refactoring_arrows/

Я не вижу, где появляется «синхронный», поскольку это не является частью определения стрелок. Кроме того, я наткнулся на этот проект на github https://github.com/cmahon/interactive-brokers, который явно рассматривает каналы как стрелки. Я вставляю определение экземпляра здесь для вашего удобства. Что мне здесь не хватает?

-- The code in this module was provided by Gabriel Gonzalez

{-# LANGUAGE RankNTypes #-}

module Pipes.Edge where

import           Control.Arrow
import           Control.Category (Category((.), id))
import           Control.Monad ((>=>))
import           Control.Monad.Trans.State.Strict (get, put)
import           Pipes
import           Pipes.Core (request, respond, (\>\), (/>/), push, (>~>))
import           Pipes.Internal (unsafeHoist)
import           Pipes.Lift (evalStateP)
import           Prelude hiding ((.), id)

newtype Edge m r a b = Edge { unEdge :: a -> Pipe a b m r }

instance (Monad m) => Category (Edge m r) where
    id  = Edge push
    (Edge p2) . (Edge p1) = Edge (p1 >~> p2)

instance (Monad m) => Arrow (Edge m r) where
    arr f = Edge (push />/ respond . f)
    first (Edge p) = Edge $ \(b, d) ->
        evalStateP d $ (up \>\ unsafeHoist lift . p />/ dn) b
      where
        up () = do
            (b, d) <- request ()
            lift $ put d
            return b
        dn c = do
            d <- lift get
            respond (c, d)

instance (Monad m) => ArrowChoice (Edge m r) where
    left (Edge k) = Edge (bef >=> (up \>\ (k />/ dn)))
      where
          bef x = case x of
              Left  b -> return b
              Right d -> do
                  _ <- respond (Right d)
                  x2 <- request ()
                  bef x2
          up () = do
              x <- request ()
              bef x
          dn c = respond (Left c)

runEdge :: (Monad m) => Edge m r a b -> Pipe a b m r
runEdge e = await >>= unEdge e

person user2812201    schedule 23.02.2017    source источник
comment
это удовлетворяет arr (f >>> g) = arr f >>> arr g? я подозреваю, что это не так, но я не уверен   -  person hao    schedule 23.02.2017
comment
Это вызвано аксиомой категории, не так ли?   -  person user2812201    schedule 23.02.2017
comment
Это сообщение Габриэля Гонсалеса содержит дополнительные комментарии к экземплярам для проталкиваемых труб, которые вы указали.   -  person duplode    schedule 24.02.2017


Ответы (1)


Рассмотрим эту трубу: yield '*' :: Pipe x Char IO (). Мы могли бы обернуть его в адаптер нового типа, такой как newtype PipeArrow a b = PipeArrow { getPipeArrow :: Pipe a b IO () }, и попытаться определить там экземпляр Arrow.

Купить, как написать first :: PipeArrow b c -> PipeArrow (b, d) (c, d), который работает на yield '*'? Канал никогда не ожидает значения от восходящего потока. Нам пришлось бы создать d из воздуха, чтобы сопровождать '*'.

Трубы удовлетворяют большинству законов для стрелок (и для ArrowChoice), но first нельзя реализовать законным способом.

Код, который вы разместили, определяет экземпляр Arrow не для Pipe, а для функции, которая принимает значение из восходящего потока и возвращает Pipe.

person danidiaz    schedule 23.02.2017
comment
дополнение к этому прекрасному ответу . - person duplode; 24.02.2017