Polysemy.Conc.Effect.Events

Documentation

data Events (e :: Type) :: Effect where

An event publisher that can be consumed from multiple threads.

Constructors

Publish :: e -> Events e m ()

Instances

type DefiningModule Events

Defined in Polysemy.Conc.Effect.Events

type DefiningModule Events = "Polysemy.Conc.Effect.Events"

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

Publish one event.

data Consume (e :: Type) :: Effect where

Consume events emitted by Events.

Constructors

Consume :: Consume e m e

Instances

type DefiningModule Consume

Defined in Polysemy.Conc.Effect.Events

type DefiningModule Consume = "Polysemy.Conc.Effect.Events"

consume :: forall e r. Member (Consume e) r => Sem r e

Consume one event emitted by Events.

subscribe :: forall e r. Member (Scoped_ (Consume e)) r => InterpreterFor (Consume e) r

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