Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
-
data
ClientSubscriptionParams
a =
ClientSubscriptionParams
{
- cspAddress :: ! LocalAddress
- cspConnectionAttemptDelay :: !( Maybe DiffTime )
- cspErrorPolicies :: ! ErrorPolicies
- clientSubscriptionWorker :: LocalSnocket -> Tracer IO ( SubscriptionTrace LocalAddress ) -> Tracer IO ( WithAddr LocalAddress ErrorPolicyTrace ) -> NetworkMutableState LocalAddress -> ClientSubscriptionParams a -> ( LocalSocket -> IO a) -> IO Void
Documentation
data ClientSubscriptionParams a Source #
ClientSubscriptionParams | |
|
clientSubscriptionWorker :: LocalSnocket -> Tracer IO ( SubscriptionTrace LocalAddress ) -> Tracer IO ( WithAddr LocalAddress ErrorPolicyTrace ) -> NetworkMutableState LocalAddress -> ClientSubscriptionParams a -> ( LocalSocket -> IO a) -> IO Void Source #
Client subscription worker keeps subsribing to the
LocalAddress
using
either unix socket or named pipe.