From b0bfe75e1ff85566387115502da7a41d71a805b6 Mon Sep 17 00:00:00 2001 From: Dmitry Zuikov Date: Sun, 22 Jan 2023 13:06:20 +0300 Subject: [PATCH] wip --- hbs2-core/lib/HBS2/Actors/Peer.hs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/hbs2-core/lib/HBS2/Actors/Peer.hs b/hbs2-core/lib/HBS2/Actors/Peer.hs index 42892cd1..888f808b 100644 --- a/hbs2-core/lib/HBS2/Actors/Peer.hs +++ b/hbs2-core/lib/HBS2/Actors/Peer.hs @@ -256,11 +256,14 @@ instance ( HasProtocol e p let sk = newSKey @(EventKey e p) k void $ runMaybeT $ do + liftIO $ print "GOOD" subs <- MaybeT $ liftIO $ atomically $ readTVar se <&> HashMap.lookup sk + liftIO $ print "VERY GOOD" void $ liftIO $ atomically $ modifyTVar' se (HashMap.delete sk) for_ subs $ \r -> do ev <- MaybeT $ pure $ fromDynamic @(EventHandler e p (PeerM e IO)) r lift $ ev d + liftIO $ print "FINE" runPeerM :: (MonadIO m, Pretty (Peer e)) => AnyStorage -> Fabriq e -> Peer e -> PeerM e m a -> m () runPeerM s bus p f = do