polysemy-conc-0.14.1.1: Polysemy effects for concurrency
Safe HaskellNone
LanguageGHC2021

Polysemy.Conc.Interpreter.Queue.TBM

Description

 
Synopsis

Documentation

interpretQueueTBMWith :: forall d (r :: EffectRow). Members '[Race, Embed IO] r => TBMQueue d -> InterpreterFor (Queue d) r Source #

Interpret Queue with a TBMQueue.

This variant expects an allocated queue as an argument.

interpretQueueTBM Source #

Arguments

:: forall d (r :: EffectRow). Members '[Resource, Race, Embed IO] r 
=> Int

Buffer size

-> InterpreterFor (Queue d) r 

Interpret Queue with a TBMQueue.