diff options
| author | Roman Smrž <roman.smrz@seznam.cz> | 2026-08-17 19:51:57 +0200 |
|---|---|---|
| committer | Roman Smrž <roman.smrz@seznam.cz> | 2026-08-18 19:25:19 +0200 |
| commit | c3da6e7e4de1edaf8f7a5a012c297a296b36dee7 (patch) | |
| tree | 915ad18c4210f8ef8d13fcc4be71a8bf785e6ea0 /src | |
| parent | 8f3abc22cff98472b4d74d0c2f7985b4cceca300 (diff) | |
Network: add getNextPeerChangeChan function
Diffstat (limited to 'src')
| -rw-r--r-- | src/Erebos/Network.hs | 4 |
1 files changed, 4 insertions, 0 deletions
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 |