Copyright (c) Moritz Clasmeier 2017 2018 BSD3 mtesseract@silverratio.net experimental POSIX None Haskell2010

Description

This module implements a high level interface for the /subscriptions/SUBSCRIPTIONS/events API.

Synopsis

# Documentation

Arguments

Conduit based interface for subscription consumption. Consumes the specified subscription using the commit strategy contained in the configuration. Each consumed event batch is then processed by the provided conduit. If an exception is thrown inside the conduit, subscription consumption will terminate.

Arguments

Consumes the specified subscription using the commit strategy contained in the configuration. Each consumed batch of subscription events is provided to the provided batch processor action. If this action throws an exception, subscription consumption will terminate.

Arguments

Similar to subscriptionSource, but the created Conduit source provides events instead of event batches.