ez/ActivityPuppy - Change RGFJ2XOW6NLJ7MDXATCSTRDCQJSOC2BWVH56HTYPBMQ4PWEB2T5QC

Hide channel implementation detail in TaskQueue handler

Created by ez on August 29, 2023

RGFJ2XOW6NLJ7MDXATCSTRDCQJSOC2BWVH56HTYPBMQ4PWEB2T5QC

Dependencies

In channels

main

Change contents

Replacement in src/lib/Puppy/TaskQueue.hs at line 31 [3.9875]

B:BD[3.10590] → [3.10590:10662]

  :: (Concurrent :> es)
  => Chan task
  -> Eff (TaskQueue task : es) a

[3.10590]

[3.10662]

  :: forall task es a. 
     (Concurrent :> es)
  => Eff (TaskQueue task : es) a

Replacement in src/lib/Puppy/TaskQueue.hs at line 35 [3.9875]

B:BD[3.10676] → [3.10676:10779]

runTaskQueue chan = interpret $ \_ -> \case
  Enqueue v -> writeChan chan v
  Dequeue -> readChan chan

[3.10676]

[3.10779]

runTaskQueue eff = do
  chan <- newChan 
  interpret (run chan) eff
  where
    run :: (Concurrent :> es)
        => Chan task
        -> LocalEnv localEs es
        -> TaskQueue task (Eff localEs) x
        -> Eff es x
    run chan _ = \case
      Enqueue v -> writeChan chan v
      Dequeue -> readChan chan

Deletion in src/app/api/Main.hs at line 14 [3.62968]
B:BD[3.63389] → [3.63389:63438]
```
import Effectful.Concurrent.Chan (Chan, newChan)
```

Replacement in src/app/api/Main.hs at line 54 [3.62968]

B:BD[3.65424] → [3.65424:65513]

              . (\x -> (newChan :: Eff _ (Chan DeliverTask)) >>= \q -> runTaskQueue q x)

[3.65424]

[3.65513]

              . runTaskQueue @DeliverTask

Replacement in src/app/api/Main.hs at line 56 [3.62968]

B:BD[3.65578] → [3.65578:65667]

              . (\x -> (newChan :: Eff _ (Chan PerformTask)) >>= \q -> runTaskQueue q x)

[3.65578]

[2.1734]

              . runTaskQueue @PerformTask