Modulepolysemy-zoo-0.8.2.0Haskell2010

Polysemy.Input.Streaming

Underlying Effect

6 declarations

datadata Input (i :: k) (m :: k1) (a :: k) where

An effect which can provide input to an application. Useful for dealing with streaming input.

valueinput :: Member (Input i) r => Sem r i

Get the next available message.

valueinputs :: Member (Input i) r => (i -> j) -> Sem r j

Apply a function to an input, cf. asks

valuerunInputConst :: i -> Sem (Input i ': r) a -> Sem r a

Run an Input effect by always giving back the same value.

valuerunInputList :: [i] -> Sem (Input (Maybe i) ': r) a -> Sem r a

Run an Input effect by providing a different element of a list each time. Returns Nothing after the list is exhausted.

valuerunInputSem :: Sem r i -> Sem (Input i ': r) a -> Sem r a

Runs an Input effect by evaluating a monadic action for each request.

3 declarations

valueyieldInput :: Member (Input i) r => Stream (Of i) (Sem r) ()

valueyieldRace :: Members '[Final IO, Input i1, Input i2] r => Stream (Of (Either i1 i2)) (Sem r) ()

valueexhaust :: Member (Input i) r => Stream (Of i) (Sem r) a

2 declarations

valuerunInputViaStream

valuerunInputViaInfiniteStream