Class StreamManager

constructor

• new StreamManager(multicodec, getConnections, addEventListener): waku.StreamManager

• Parameters

  • multicodec: string
  • getConnections: ((peerId?) => Connection[])
    • • (peerId?): Connection[]

      • Return a list of all connections this node has open, optionally filtering by a PeerId

        Parameters

        • Optional peerId: PeerId

        Returns Connection[]

        Example

        for (const connection of libp2p.getConnections()) {
          console.log(peerId, connection.remoteAddr.toString())
          // Logs the PeerId string and the observed remote multiaddr of each Connection
        }
        Copy

  • addEventListener: (<K>(type, listener, options?) => void)
    • • <K>(type, listener, options?): void

      • Type Parameters

        • K extends keyof Libp2pEvents<Libp2pServices>

        Parameters

        • type: K
        • listener: null | EventHandler<Libp2pEvents<Libp2pServices>[K]>
        • Optional options: boolean | AddEventListenerOptions

        Returns void

  Returns waku.StreamManager

addEventListener

getConnections

multicodec

getStream

• getStream(peer): Promise<Stream>

• Parameters

  • peer: Peer

  Returns Promise<Stream>