Network.ZGossip.ZMQ

Documentation

zgossipDealer :: MonadIO m => Endpoint -> ByteString -> TBQueue ZGSCmd -> (ZGSMsg -> IO ()) -> m a

zgossipRouter :: (Foldable t, MonadIO m) => Endpoint -> (ByteString -> ZGSCmd -> IO (t (ByteString, ZGSCmd))) -> m a