runSubscriptionR ::
(Monad m, MonadBaseControl IO m, MonadResource m, MonadReader r m, L.HasNakadiConfig r Config)
=> SubscriptionEventStream -- ^ Connection information for the Subscription
-> ConduitM ()
Void
(ReaderT SubscriptionEventStreamContext m)
r -- ^ Subscription Conduit to run
-> m r
We are forcing the conduit and the final value to return r which is the type parameter bound for the configuration. I will try to do a PR for this.
I noticed an issue here:
We are forcing the conduit and the final value to return
r
which is the type parameter bound for the configuration. I will try to do a PR for this.