Class FilterCore

Index

Constructors

Properties

Methods

ping start stop subscribe unsubscribe unsubscribeAll

Constructors

constructor

new FilterCore(
handleIncomingMessage: IncomingMessageHandler,
libp2p: Libp2p,
): FilterCore
Parameters
- handleIncomingMessage: IncomingMessageHandler
- libp2p: Libp2p
Returns FilterCore
- Defined in core/src/lib/filter/filter.ts:43

Properties

`Readonly`multicodec

multicodec: string = FilterCodecs.SUBSCRIBE

Methods

ping

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

start

start(): Promise<void>
Returns Promise<void>
- Defined in core/src/lib/filter/filter.ts:53

stop

stop(): Promise<void>
Returns Promise<void>
- Defined in core/src/lib/filter/filter.ts:63

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

unsubscribe

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

unsubscribeAll

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