rename ObjectDiffusion peer functions

Author: tbagrel1

ouroboros-network-protocols/src/Ouroboros/Network/Protocol/ObjectDiffusion/Inbound.hs

@@ -21,8 +21,8 @@ module Ouroboros.Network.Protocol.ObjectDiffusion.Inbound
     Collect (..),
 
     -- * Execution as a typed protocol
-    objectDiffusionInitInboundPeerPipelined,
-    objectDiffusionNonInitInboundPeerPipelined,
+    objectDiffusionInboundClientPeerPipelined,
+    objectDiffusionInboundServerPeerPipelined,
   )
 where
 
@@ -104,23 +104,23 @@ inboundRun (CollectPipelined mNone collect) =
         (Effect . fmap inboundRun . collect)
 
 -- | Transform a 'ObjectDiffusionInboundPipelined' into a 'PeerPipelined'.
-objectDiffusionInitInboundPeerPipelined ::
+objectDiffusionInboundClientPeerPipelined ::
   forall objectId object m a.
   (Functor m) =>
   ObjectDiffusionInboundPipelined objectId object m a ->
   PeerPipelined (ObjectDiffusion InboundAgency objectId object) AsInbound StInit m a
-objectDiffusionInitInboundPeerPipelined (ObjectDiffusionInboundPipelined inboundSt) =
+objectDiffusionInboundClientPeerPipelined (ObjectDiffusionInboundPipelined inboundSt) =
   PeerPipelined $
     Yield ReflInboundAgency MsgInit $
     Effect $
       inboundRun <$> inboundSt
 
-objectDiffusionNonInitInboundPeerPipelined ::
+objectDiffusionInboundServerPeerPipelined ::
   forall objectId object m a.
   (Functor m) =>
   ObjectDiffusionInboundPipelined objectId object m a ->
   PeerPipelined (ObjectDiffusion OutboundAgency objectId object) AsInbound StInit m a
-objectDiffusionNonInitInboundPeerPipelined (ObjectDiffusionInboundPipelined inboundSt) =
+objectDiffusionInboundServerPeerPipelined (ObjectDiffusionInboundPipelined inboundSt) =
   PeerPipelined $
      Await @_ @_ @(Pipelined Z (Collect objectId object)) ReflOutboundAgency
       (\MsgInit -> Effect (inboundRun <$> inboundSt))

ouroboros-network-protocols/src/Ouroboros/Network/Protocol/ObjectDiffusion/Outbound.hs

@@ -25,8 +25,8 @@ module Ouroboros.Network.Protocol.ObjectDiffusion.Outbound
     BlockingReplyList (..),
 
     -- * Execution as a typed protocol
-    objectDiffusionNonInitOutboundPeer,
-    objectDiffusionInitOutboundPeer,
+    objectDiffusionOutboundServerPeer,
+    objectDiffusionOutboundClientPeer,
   )
 where
 
@@ -112,22 +112,22 @@ outboundRun OutboundStIdle {recvMsgRequestObjectIds, recvMsgRequestObjects} =
           (outboundRun k)
 
 -- | A non-pipelined 'Peer' representing the 'ObjectDiffusionOutbound'.
-objectDiffusionNonInitOutboundPeer ::
+objectDiffusionOutboundServerPeer ::
   forall txid tx m a.
   (Monad m) =>
   ObjectDiffusionOutbound txid tx m a ->
   Peer (ObjectDiffusion InboundAgency txid tx) AsOutbound NonPipelined StInit m a
-objectDiffusionNonInitOutboundPeer (ObjectDiffusionOutbound outboundSt) =
+objectDiffusionOutboundServerPeer (ObjectDiffusionOutbound outboundSt) =
     -- We need to assist GHC to infer the existentially quantified `c` as
     -- `Collect objectId object`
     Await ReflInboundAgency
       (\MsgInit -> Effect (outboundRun <$> outboundSt))
 
-objectDiffusionInitOutboundPeer ::
+objectDiffusionOutboundClientPeer ::
   forall txid tx m a.
   (Monad m) =>
   ObjectDiffusionOutbound txid tx m a ->
   Peer (ObjectDiffusion OutboundAgency txid tx) AsOutbound NonPipelined StInit m a
-objectDiffusionInitOutboundPeer (ObjectDiffusionOutbound outboundSt) =
+objectDiffusionOutboundClientPeer (ObjectDiffusionOutbound outboundSt) =
   Yield ReflOutboundAgency MsgInit $
     Effect $ outboundRun <$> outboundSt