Safe Haskell	None
Language	GHC2021

Polysemy.Conc.Effect.Events

Description

Synopsis

data Events e (a :: Type -> Type) b where
- Publish :: forall e (a :: Type -> Type). e -> Events e a ()
publish :: forall e (r :: EffectRow). Member (Events e) r => e -> Sem r ()
data Consume e (a :: Type -> Type) b where
- Consume :: forall e (a :: Type -> Type). Consume e a e
consume :: forall e (r :: EffectRow). Member (Consume e) r => Sem r e
subscribe :: forall e (r :: EffectRow). Member (Scoped_ (Consume e)) r => InterpreterFor (Consume e) r

Documentation

data Events e (a :: Type -> Type) b where Source #

An event publisher that can be consumed from multiple threads.

Constructors

Publish :: forall e (a :: Type -> Type). e -> Events e a ()

publish :: forall e (r :: EffectRow). Member (Events e) r => e -> Sem r () Source #

Publish one event.

data Consume e (a :: Type -> Type) b where Source #

Consume events emitted by Events.

Constructors

Consume :: forall e (a :: Type -> Type). Consume e a e

Consume one event emitted by Events.

Create a new scope for Events, causing the nested program to get its own copy of the event stream. To be used with interpretEventsChan.