{- |
This module introduces 'ResamplingBuffer's,
which are primitives that consume and produce data at different rates.
Just as schedules form the boundaries between different clocks,
(resampling) buffers form the boundaries between
synchronous signal functions ticking at different speeds.
-}

{-# LANGUAGE RankNTypes #-}
{-# LANGUAGE RecordWildCards #-}
{-# LANGUAGE TypeFamilies #-}
module FRP.Rhine.ResamplingBuffer
  ( module FRP.Rhine.ResamplingBuffer
  , module FRP.Rhine.Clock
  )
  where

-- rhine
import FRP.Rhine.Clock

-- A quick note on naming conventions, to whoever cares:
-- . Call a single clock @cl@.
-- . Call several clocks @cl1@, @cl2@ etc. in most situations.
-- . Call it @cla@, @clb@ etc. when they are 'In' or 'Out' clocks,
-- i.e. associated to particular boundary types @a@, @b@ etc.,

{- | A stateful buffer from which one may 'get' a value,
or to which one may 'put' a value,
depending on the clocks.
`ResamplingBuffer`s can be clock-polymorphic,
or specific to certain clocks.

* 'm': Monad in which the 'ResamplingBuffer' may have side effects
* 'cla': The clock at which data enters the buffer
* 'clb': The clock at which data leaves the buffer
* 'a': The input type
* 'b': The output type
-}
data ResamplingBuffer m cla clb a b = ResamplingBuffer
  { ResamplingBuffer m cla clb a b
-> TimeInfo cla -> a -> m (ResamplingBuffer m cla clb a b)
put
      :: TimeInfo cla
      -> a
      -> m (   ResamplingBuffer m cla clb a b)
    -- ^ Store one input value of type 'a' at a given time stamp,
    --   and return a continuation.
  , ResamplingBuffer m cla clb a b
-> TimeInfo clb -> m (b, ResamplingBuffer m cla clb a b)
get
      :: TimeInfo clb
      -> m (b, ResamplingBuffer m cla clb a b)
    -- ^ Retrieve one output value of type 'b' at a given time stamp,
    --   and a continuation.
  }

-- | A type synonym to allow for abbreviation.
type ResBuf m cla clb a b = ResamplingBuffer m cla clb a b


-- | Hoist a 'ResamplingBuffer' along a monad morphism.
hoistResamplingBuffer
  :: (Monad m1, Monad m2)
  => (forall c. m1 c -> m2 c)
  -> ResamplingBuffer m1 cla clb a b
  -> ResamplingBuffer m2 cla clb a b
hoistResamplingBuffer :: (forall c. m1 c -> m2 c)
-> ResamplingBuffer m1 cla clb a b
-> ResamplingBuffer m2 cla clb a b
hoistResamplingBuffer forall c. m1 c -> m2 c
hoist ResamplingBuffer {TimeInfo cla -> a -> m1 (ResamplingBuffer m1 cla clb a b)
TimeInfo clb -> m1 (b, ResamplingBuffer m1 cla clb a b)
get :: TimeInfo clb -> m1 (b, ResamplingBuffer m1 cla clb a b)
put :: TimeInfo cla -> a -> m1 (ResamplingBuffer m1 cla clb a b)
get :: forall (m :: Type -> Type) cla clb a b.
ResamplingBuffer m cla clb a b
-> TimeInfo clb -> m (b, ResamplingBuffer m cla clb a b)
put :: forall (m :: Type -> Type) cla clb a b.
ResamplingBuffer m cla clb a b
-> TimeInfo cla -> a -> m (ResamplingBuffer m cla clb a b)
..} = ResamplingBuffer :: forall (m :: Type -> Type) cla clb a b.
(TimeInfo cla -> a -> m (ResamplingBuffer m cla clb a b))
-> (TimeInfo clb -> m (b, ResamplingBuffer m cla clb a b))
-> ResamplingBuffer m cla clb a b
ResamplingBuffer
  { put :: TimeInfo cla -> a -> m2 (ResamplingBuffer m2 cla clb a b)
put = ((((forall c. m1 c -> m2 c)
-> ResamplingBuffer m1 cla clb a b
-> ResamplingBuffer m2 cla clb a b
forall (m1 :: Type -> Type) (m2 :: Type -> Type) cla clb a b.
(Monad m1, Monad m2) =>
(forall c. m1 c -> m2 c)
-> ResamplingBuffer m1 cla clb a b
-> ResamplingBuffer m2 cla clb a b
hoistResamplingBuffer forall c. m1 c -> m2 c
hoist (ResamplingBuffer m1 cla clb a b
 -> ResamplingBuffer m2 cla clb a b)
-> m2 (ResamplingBuffer m1 cla clb a b)
-> m2 (ResamplingBuffer m2 cla clb a b)
forall (f :: Type -> Type) a b. Functor f => (a -> b) -> f a -> f b
<$>) (m2 (ResamplingBuffer m1 cla clb a b)
 -> m2 (ResamplingBuffer m2 cla clb a b))
-> (m1 (ResamplingBuffer m1 cla clb a b)
    -> m2 (ResamplingBuffer m1 cla clb a b))
-> m1 (ResamplingBuffer m1 cla clb a b)
-> m2 (ResamplingBuffer m2 cla clb a b)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. m1 (ResamplingBuffer m1 cla clb a b)
-> m2 (ResamplingBuffer m1 cla clb a b)
forall c. m1 c -> m2 c
hoist) (m1 (ResamplingBuffer m1 cla clb a b)
 -> m2 (ResamplingBuffer m2 cla clb a b))
-> (a -> m1 (ResamplingBuffer m1 cla clb a b))
-> a
-> m2 (ResamplingBuffer m2 cla clb a b)
forall b c a. (b -> c) -> (a -> b) -> a -> c
.) ((a -> m1 (ResamplingBuffer m1 cla clb a b))
 -> a -> m2 (ResamplingBuffer m2 cla clb a b))
-> (TimeInfo cla -> a -> m1 (ResamplingBuffer m1 cla clb a b))
-> TimeInfo cla
-> a
-> m2 (ResamplingBuffer m2 cla clb a b)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. TimeInfo cla -> a -> m1 (ResamplingBuffer m1 cla clb a b)
put
  , get :: TimeInfo clb -> m2 (b, ResamplingBuffer m2 cla clb a b)
get = ((ResamplingBuffer m1 cla clb a b
 -> ResamplingBuffer m2 cla clb a b)
-> (b, ResamplingBuffer m1 cla clb a b)
-> (b, ResamplingBuffer m2 cla clb a b)
forall (a :: Type -> Type -> Type) b c d.
Arrow a =>
a b c -> a (d, b) (d, c)
second ((forall c. m1 c -> m2 c)
-> ResamplingBuffer m1 cla clb a b
-> ResamplingBuffer m2 cla clb a b
forall (m1 :: Type -> Type) (m2 :: Type -> Type) cla clb a b.
(Monad m1, Monad m2) =>
(forall c. m1 c -> m2 c)
-> ResamplingBuffer m1 cla clb a b
-> ResamplingBuffer m2 cla clb a b
hoistResamplingBuffer forall c. m1 c -> m2 c
hoist) ((b, ResamplingBuffer m1 cla clb a b)
 -> (b, ResamplingBuffer m2 cla clb a b))
-> m2 (b, ResamplingBuffer m1 cla clb a b)
-> m2 (b, ResamplingBuffer m2 cla clb a b)
forall (f :: Type -> Type) a b. Functor f => (a -> b) -> f a -> f b
<$>) (m2 (b, ResamplingBuffer m1 cla clb a b)
 -> m2 (b, ResamplingBuffer m2 cla clb a b))
-> (TimeInfo clb -> m2 (b, ResamplingBuffer m1 cla clb a b))
-> TimeInfo clb
-> m2 (b, ResamplingBuffer m2 cla clb a b)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. m1 (b, ResamplingBuffer m1 cla clb a b)
-> m2 (b, ResamplingBuffer m1 cla clb a b)
forall c. m1 c -> m2 c
hoist (m1 (b, ResamplingBuffer m1 cla clb a b)
 -> m2 (b, ResamplingBuffer m1 cla clb a b))
-> (TimeInfo clb -> m1 (b, ResamplingBuffer m1 cla clb a b))
-> TimeInfo clb
-> m2 (b, ResamplingBuffer m1 cla clb a b)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. TimeInfo clb -> m1 (b, ResamplingBuffer m1 cla clb a b)
get
  }