Class FilterCore

Hierarchy

  • BaseProtocol
    • FilterCore

Implements

Constructors

constructor

Properties

addLibp2pEventListener components handleIncomingMessage multicodec onRequest pubsubTopics removeLibp2pEventListener streamManager

Methods

getStream ping subscribe unsubscribe unsubscribeAll

Constructors

constructor

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

  • Parameters

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

        • Parameters

          • pubsubTopic: string
          • wakuMessage: WakuMessage
          • peerIdStr: string

          Returns Promise<void>

    • pubsubTopics: string[]
    • libp2p: Libp2p

    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

Protected components

components: Components

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

Methods

Protected getStream

  • getStream(peerId): Promise<Stream>

  • Parameters

    • peerId: PeerId

    Returns Promise<Stream>

ping

subscribe

  • subscribe(pubsubTopic, peerId, contentTopics): Promise<CoreProtocolResult>

  • Parameters

    • pubsubTopic: string
    • peerId: PeerId
    • contentTopics: string[]

    Returns Promise<CoreProtocolResult>

unsubscribe

  • unsubscribe(pubsubTopic, peerId, contentTopics): Promise<CoreProtocolResult>

  • Parameters

    • pubsubTopic: string
    • peerId: PeerId
    • contentTopics: string[]

    Returns Promise<CoreProtocolResult>

unsubscribeAll

  • unsubscribeAll(pubsubTopic, peerId): Promise<CoreProtocolResult>

  • Parameters

    • pubsubTopic: string
    • peerId: PeerId

    Returns Promise<CoreProtocolResult>

Settings

Member Visibility

Theme

On This Page

constructoraddLibp2pEventListenercomponentshandleIncomingMessagemulticodeconRequestpubsubTopicsremoveLibp2pEventListenerstreamManagergetStreampingsubscribeunsubscribeunsubscribeAll