Polysemy.Conc.Effect.Events

Documentation

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"

newtype EventToken token

Marker for the Scoped token for Events.

Constructors

EventToken

Fields

• unEventToken :: token

Instances

Eq token => Eq (EventToken token)

Defined in Polysemy.Conc.Effect.Events

Methods

(==) :: EventToken token -> EventToken token -> Bool

(/=) :: EventToken token -> EventToken token -> Bool

Show token => Show (EventToken token)

Defined in Polysemy.Conc.Effect.Events

Methods

showsPrec :: Int -> EventToken token -> ShowS

show :: EventToken token -> String

showList :: [EventToken token] -> ShowS

Generic (EventToken token)

Defined in Polysemy.Conc.Effect.Events

Associated Types

type Rep (EventToken token) :: Type -> Type

Methods

from :: EventToken token -> Rep (EventToken token) x

to :: Rep (EventToken token) x -> EventToken token

type Rep (EventToken token)

Defined in Polysemy.Conc.Effect.Events

type Rep (EventToken token) = D1 ('MetaData "EventToken" "Polysemy.Conc.Effect.Events" "polysemy-conc-0.3.0.0-inplace" 'True) (C1 ('MetaCons "EventToken" 'PrefixI 'True) (S1 ('MetaSel ('Just "unEventToken") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 token)))

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

An event publisher that can be consumed from multiple threads.

Constructors

Publish :: e -> Events token e m ()

Instances

type DefiningModule Events

Defined in Polysemy.Conc.Effect.Events

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

subscribe :: forall e token r. Member (Scoped (EventToken token) (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.