Safe Haskell | None |
---|---|
Language | Haskell2010 |
- type Sos a = ResourceT (ExceptT SosException IO) a
- runSos :: Sos a -> IO a
- sosEnqueueJobs :: (Applicative m, MonadError SosException m, MonadResource m) => [Rule] -> Stream (Of FileEvent) m a -> JobQueue -> m a
- module Sos.Exception
- module Sos.FileEvent
- module Sos.Job
- module Sos.JobQueue
- module Sos.Rule
- module Sos.Template
Documentation
sosEnqueueJobs :: (Applicative m, MonadError SosException m, MonadResource m) => [Rule] -> Stream (Of FileEvent) m a -> JobQueue -> m a Source #
Enqueue jobs on the given job queue resulting from to apply the given rules to each emitted file event from the given stream. This function returns when the stream is exhausted.
module Sos.Exception
module Sos.FileEvent
module Sos.Job
module Sos.JobQueue
module Sos.Rule
module Sos.Template