Knit.Utilities.Streamly

Documentation

data StreamlyM a

IO with a ReaderTlayer we can use to expose effects we need. For now just logging.

Instances

Monad StreamlyM

Defined in Knit.Utilities.Streamly

Methods

(>>=) :: StreamlyM a -> (a -> StreamlyM b) -> StreamlyM b

(>>) :: StreamlyM a -> StreamlyM b -> StreamlyM b

return :: a -> StreamlyM a

Functor StreamlyM

Defined in Knit.Utilities.Streamly

Methods

fmap :: (a -> b) -> StreamlyM a -> StreamlyM b

(<$) :: a -> StreamlyM b -> StreamlyM a

Applicative StreamlyM

Defined in Knit.Utilities.Streamly

Methods

pure :: a -> StreamlyM a

(<*>) :: StreamlyM (a -> b) -> StreamlyM a -> StreamlyM b

liftA2 :: (a -> b -> c) -> StreamlyM a -> StreamlyM b -> StreamlyM c

(*>) :: StreamlyM a -> StreamlyM b -> StreamlyM b

(<*) :: StreamlyM a -> StreamlyM b -> StreamlyM a

MonadIO StreamlyM

Defined in Knit.Utilities.Streamly

Methods

liftIO :: IO a -> StreamlyM a

MonadThrow StreamlyM

Defined in Knit.Utilities.Streamly

Methods

throwM :: Exception e => e -> StreamlyM a

MonadCatch StreamlyM

Defined in Knit.Utilities.Streamly

Methods

catch :: Exception e => StreamlyM a -> (e -> StreamlyM a) -> StreamlyM a

MonadReader StreamlyEffects StreamlyM

Defined in Knit.Utilities.Streamly

Methods

ask :: StreamlyM StreamlyEffects

local :: (StreamlyEffects -> StreamlyEffects) -> StreamlyM a -> StreamlyM a

reader :: (StreamlyEffects -> a) -> StreamlyM a

MonadBase IO StreamlyM

Defined in Knit.Utilities.Streamly

Methods

liftBase :: IO α -> StreamlyM α

MonadBaseControl IO StreamlyM

Defined in Knit.Utilities.Streamly

Associated Types

type StM StreamlyM a

Methods

liftBaseWith :: (RunInBase StreamlyM IO -> IO a) -> StreamlyM a

restoreM :: StM StreamlyM a -> StreamlyM a

type StM StreamlyM a

Defined in Knit.Utilities.Streamly

type StM StreamlyM a = StM (ReaderT StreamlyEffects IO) a

data StreamlyEffects

record-of-functions to hold access to effects we want to have available in this ReaderT over IO wrapper for Streamly

Constructors

StreamlyEffects

Fields

• logIO :: LogSeverity -> Text -> IO ()

Instances

MonadReader StreamlyEffects StreamlyM

Defined in Knit.Utilities.Streamly

Methods

ask :: StreamlyM StreamlyEffects

local :: (StreamlyEffects -> StreamlyEffects) -> StreamlyM a -> StreamlyM a

reader :: (StreamlyEffects -> a) -> StreamlyM a

streamlyToKnit :: (Member (Embed IO) r, LogWithPrefixesLE r) => StreamlyM a -> Sem r a

lift a StreamlyM computation into a Sem computation

streamlyToKnitS :: (Member (Embed IO) r, LogWithPrefixesLE r) => SerialT StreamlyM a -> SerialT (Sem r) a

Serial streams work fine over Sem, so we can lift the effectful serial stream into Sem r without running.

logStreamly :: LogSeverity -> Text -> StreamlyM ()

Use the logging function in the Reader to log in a StreamlyM context.