From 83698d8ae9a3e5648b751b71eaa04b0ab627fee3 Mon Sep 17 00:00:00 2001 From: Daniel Firth Date: Mon, 15 Apr 2024 19:09:06 +0000 Subject: [PATCH] Add sequenceInbound --- hydra-node/src/Hydra/Network.hs | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/hydra-node/src/Hydra/Network.hs b/hydra-node/src/Hydra/Network.hs index 143b367e5ed..44fcc3c1a2e 100644 --- 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)