FloodSub {.public.} = ref object of PubSub
  floodsub*: PeerTable
  seen*: TimedCache[MessageId]
  seenSalt*: seq[byte]

FloodSubCodec = "/floodsub/1.0.0"

proc addSeen(f: FloodSub; msgId: MessageId): bool {....raises: [], tags: [].}

proc firstSeen(f: FloodSub; msgId: MessageId): Moment {....raises: [], tags: [].}

proc handleSubscribe(f: FloodSub; peer: PubSubPeer; topic: string;
                     subscribe: bool) {....raises: [], tags: [RootEffect,
    WriteIOEffect, TimeEffect].}

proc hasSeen(f: FloodSub; msgId: MessageId): bool {....raises: [], tags: [].}

method init(f: FloodSub) {....raises: [], tags: [RootEffect].}

method initPubSub(f: FloodSub) {....raises: [InitializationError], raises: [],
                                 tags: [RootEffect].}

method publish(f: FloodSub; topic: string; data: seq[byte]): Future[int] {.
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}

method rpcHandler(f: FloodSub; peer: PubSubPeer; data: seq[byte]): Future[void] {.
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}

method unsubscribePeer(f: FloodSub; peer: PeerId) {....raises: [],
    tags: [WriteIOEffect, TimeEffect].}