Documentation

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

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