ouroboros-network-framework-0.1.0.1

Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.Subscription.Client

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 #

Constructors

ClientSubscriptionParams
Fields cspAddress :: ! LocalAddress unix socket or named pipe address cspConnectionAttemptDelay :: !( Maybe DiffTime ) delay between connection attempts cspErrorPolicies :: ! ErrorPolicies error policies for subscription worker

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.