Class FilterCore

Index

Constructors

constructor

new FilterCore(handleIncomingMessage, pubsubTopics, libp2p): waku_filter.FilterCore
Parameters
- handleIncomingMessage: IncomingMessageHandler
- pubsubTopics: string[]
- libp2p: Libp2p
Returns waku_filter.FilterCore
- Defined in packages/core/src/lib/filter/filter.ts:44

Properties

`Readonly` multicodec

multicodec: string = FilterCodecs.SUBSCRIBE

`Readonly` pubsubTopics

pubsubTopics: string[]

`Private` streamManager

streamManager: StreamManager

`Private` `Static` `Optional` handleIncomingMessage

handleIncomingMessage?: IncomingMessageHandler

Methods

`Private` onRequest

onRequest(streamData): void
Parameters
- streamData: IncomingStreamData
Returns void
- Defined in packages/core/src/lib/filter/filter.ts:305

ping

ping(peerId): Promise<CoreProtocolResult>
Parameters
- peerId: PeerId
Returns Promise<CoreProtocolResult>
- Defined in packages/core/src/lib/filter/filter.ts:234

subscribe

subscribe(pubsubTopic, peerId, contentTopics): Promise<CoreProtocolResult>
Parameters
- pubsubTopic: string
- peerId: PeerId
- contentTopics: string[]
Returns Promise<CoreProtocolResult>
- Defined in packages/core/src/lib/filter/filter.ts:86

unsubscribe

unsubscribe(pubsubTopic, peerId, contentTopics): Promise<CoreProtocolResult>
Parameters
- pubsubTopic: string
- peerId: PeerId
- contentTopics: string[]
Returns Promise<CoreProtocolResult>
- Defined in packages/core/src/lib/filter/filter.ts:140

unsubscribeAll

unsubscribeAll(pubsubTopic, peerId): Promise<CoreProtocolResult>
Parameters
- pubsubTopic: string
- peerId: PeerId
Returns Promise<CoreProtocolResult>
- Defined in packages/core/src/lib/filter/filter.ts:186