libp2prs-floodsub
the baseline flooding protocol
This is the canonical pubsub implementation for libp2p-rs.
Usage
step1: create floodsub and get handler
let floodsub = ;
let handler = floodsub.;
step2: register handler to swarm
let swarm =
.
.
.
.;
step3: get floodsub control and then start with swarm control
let floodsub_control = floodsub.;
floodsub.;
step4: start swarm
// listen on
swarm..;
// start swarm
swarm.;
// new connection
swarm_control..await.;
step5: publish/subscribe/ls/getPeers
subscribe
;
publish
floodsub_control..await;
ls
floodsub_control..await;
getPeers
floodsub_control.;
TODO list:
- config item: sign strict
- filter repetitive message to prevent over flood
- blacklist