Add sequenceInbound

input-output-hk · Apr 16, 2024 · 83698d8 · 83698d8
1 parent fec096e
commit 83698d8
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/hydra-node/src/Hydra/Network.hs b/hydra-node/src/Hydra/Network.hs
@@ -26,6 +26,7 @@ module Hydra.Network (
   mapInboundM,
   contramapOutbound,
   contramapOutboundM,
+  sequenceInbound,
   close,
 ) where
 
@@ -91,6 +92,13 @@ contramapOutboundM ::
   NetworkComponent m inbound outbound' a
 contramapOutboundM f withBaseNetwork callback action = withBaseNetwork callback (action . contramapNetworkM f)
 
+sequenceInbound ::
+  Traversable t =>
+  Applicative f =>
+  NetworkComponent m (t (f inbound)) outbound a ->
+  NetworkComponent m (f (t inbound)) outbound a
+sequenceInbound withBaseNetwork callback = withBaseNetwork (callback . sequenceA)
+
 -- * Types used by concrete implementations
 
 -- ** PortNumber (Orphans)