Class FilterCore

Hierarchy

  • BaseProtocol
    • FilterCore

Implements

Constructors

constructor

Properties

addLibp2pEventListener handleIncomingMessage multicodec onRequest pubsubTopics removeLibp2pEventListener streamManager

Accessors

peerStore

Methods

allPeers connectedPeers getPeers getStream ping subscribe unsubscribe unsubscribeAll

Constructors

constructor

  • new FilterCore(handleIncomingMessage, libp2p, options?): waku.waku_filter.FilterCore

  • Parameters

    • handleIncomingMessage: ((pubsubTopic, wakuMessage) => Promise<void>)
        • (pubsubTopic, wakuMessage): Promise<void>

        • Parameters

          • pubsubTopic: string
          • wakuMessage: WakuMessage

          Returns Promise<void>

    • libp2p: Libp2p
    • Optional options: ProtocolCreateOptions

    Returns waku.waku_filter.FilterCore

Properties

Readonly addLibp2pEventListener

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

Type declaration

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

    • Type Parameters

      • K extends keyof Libp2pEvents<ServiceMap>

      Parameters

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

      Returns void

Private handleIncomingMessage

handleIncomingMessage: any

multicodec

multicodec: string

Private onRequest

onRequest: any

Readonly pubsubTopics

pubsubTopics: string[]

Readonly removeLibp2pEventListener

removeLibp2pEventListener: {
    <K>(type, listener?, options?): void;
    (type, listener?, options?): void;
}

Type declaration

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

    • Type Parameters

      • K extends keyof Libp2pEvents<ServiceMap>

      Parameters

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

      Returns void

    • (type, listener?, options?): void

    • Parameters

      • type: string
      • Optional listener: EventHandler<Event>
      • Optional options: boolean | EventListenerOptions

      Returns void

Protected streamManager

streamManager: waku.StreamManager

Accessors

peerStore

  • get peerStore(): PeerStore

  • Returns PeerStore

Methods

allPeers

  • allPeers(): Promise<Peer[]>

  • Returns known peers from the address book (libp2p.peerStore) that support the class protocol. Waku may or may not be currently connected to these peers.

    Returns Promise<Peer[]>

connectedPeers

  • connectedPeers(): Promise<Peer[]>

  • Returns Promise<Peer[]>

getPeers

  • getPeers(__namedParameters?): Promise<Peer[]>

  • Retrieves a list of connected peers that support the protocol. The list is sorted by latency.

    Parameters

    • Optional __namedParameters: {
          maxBootstrapPeers: number;
          numPeers: number;
      }
      • maxBootstrapPeers: number
      • numPeers: number

    Returns Promise<Peer[]>

    A list of peers that support the protocol sorted by latency.

Protected getStream

  • getStream(peer): Promise<Stream>

  • Parameters

    • peer: Peer

    Returns Promise<Stream>

ping

  • ping(peer): Promise<void>

  • Parameters

    • peer: Peer

    Returns Promise<void>

subscribe

  • subscribe(pubsubTopic, peer, contentTopics): Promise<void>

  • Parameters

    • pubsubTopic: string
    • peer: Peer
    • contentTopics: string[]

    Returns Promise<void>

unsubscribe

  • unsubscribe(pubsubTopic, peer, contentTopics): Promise<void>

  • Parameters

    • pubsubTopic: string
    • peer: Peer
    • contentTopics: string[]

    Returns Promise<void>

unsubscribeAll

  • unsubscribeAll(pubsubTopic, peer): Promise<void>

  • Parameters

    • pubsubTopic: string
    • peer: Peer

    Returns Promise<void>

Settings

Member Visibility

Theme

On This Page

constructoraddLibp2pEventListenerhandleIncomingMessagemulticodeconRequestpubsubTopicsremoveLibp2pEventListenerstreamManagerpeerStoreallPeersconnectedPeersgetPeersgetStreampingsubscribeunsubscribeunsubscribeAll

Generated using TypeDoc