polysemy-conc-0.8.0.0: lib/Polysemy/Conc/AtomicState.hs

-- |Description: AtomicState Interpreters
module Polysemy.Conc.AtomicState where

import Control.Concurrent.STM (newTVarIO)

-- |Convenience wrapper around 'runAtomicStateTVar' that creates a new 'Control.Concurrent.STM.TVar'.
interpretAtomic ::
  ∀ a r .
  Member (Embed IO) r =>
  a ->
  InterpreterFor (AtomicState a) r
interpretAtomic initial sem = do
  tv <- embed (newTVarIO initial)
  runAtomicStateTVar tv sem
{-# inline interpretAtomic #-}