nakadi-client-0.5.0.3: Client library for the Nakadi Event Broker

Copyright(c) Moritz Schulte 2017 2018
LicenseBSD3
Maintainermtesseract@silverratio.net
Stabilityexperimental
PortabilityPOSIX
Safe HaskellNone
LanguageHaskell2010

Network.Nakadi.Subscriptions.Events

Description

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

Documentation

subscriptionProcessConduit :: (MonadNakadi b m, MonadMask m, FromJSON a, HasNakadiSubscriptionCursor c) => Maybe ConsumeParameters -> SubscriptionId -> ConduitM (SubscriptionEventStreamBatch a) c m () -> m () Source #

subscriptionProcess :: (MonadNakadi b m, MonadMask m, FromJSON a) => Maybe ConsumeParameters -> SubscriptionId -> (SubscriptionEventStreamBatch a -> m ()) -> m () Source #