From c3da6e7e4de1edaf8f7a5a012c297a296b36dee7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Roman=20Smr=C5=BE?= Date: Mon, 17 Aug 2026 19:51:57 +0200 Subject: Network: add getNextPeerChangeChan function --- src/Erebos/Network.hs | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'src/Erebos/Network.hs') diff --git a/src/Erebos/Network.hs b/src/Erebos/Network.hs index b98d007..609bb4c 100644 --- a/src/Erebos/Network.hs +++ b/src/Erebos/Network.hs @@ -4,6 +4,7 @@ module Erebos.Network ( stopServer, getCurrentPeerList, getNextPeerChange, + getNextPeerChangeChan, getServerAddresses, ServerOptions(..), serverIdentity, defaultServerOptions, @@ -121,6 +122,9 @@ getCurrentPeerList = fmap M.elems . readMVar . serverPeers getNextPeerChange :: Server -> IO Peer getNextPeerChange = atomically . readTChan . serverChanPeer +getNextPeerChangeChan :: Server -> IO (TChan Peer) +getNextPeerChangeChan = atomically . dupTChan . serverChanPeer + data ServerOptions = ServerOptions { serverPort :: PortNumber , serverRetryUnspecifiedPort :: Bool -- cgit v1.2.3