- Preparing search index...
- The search index is not available
js-waku
Properties
Private decoders
decoders
: Map<string, Set<Decoder<any>>>pubSubTopic
pubSubTopic: string
Methods
Private addCallback
- addCallback(requestId: string, callback: FilterCallback<any>): void
-
Returns void
Private addDecoders
- addDecoders<T>(decoders: Map<string, Decoder<T>[]>): void
-
Parameters
-
decoders: Map<string, Decoder<T>[]>
Returns void
Private deleteCallback
- deleteCallback(requestId: string): void
-
Returns void
Private deleteDecoders
- deleteDecoders<T>(decoders: Map<string, Decoder<T>[]>): void
-
Parameters
-
decoders: Map<string, Decoder<T>[]>
Returns void
Private getPeer
- getPeer(peerId?: PeerId): Promise<Peer>
-
Returns Promise<Peer>
Private newStream
- newStream(peer: Peer): Promise<Stream>
-
Returns Promise<Stream>
Private onRequest
- onRequest(streamData: IncomingStreamData): void
-
Parameters
-
streamData: IncomingStreamData
Returns void
peers
- peers(): Promise<Peer[]>
-
Returns Promise<Peer[]>
Private pushMessages
- pushMessages(requestId: string, messages: WakuMessage[]): Promise<void>
-
Returns Promise<void>
randomPeer
- randomPeer(): Promise<undefined | Peer>
-
Returns Promise<undefined | Peer>
Private unsubscribe
- unsubscribe(topic: string, contentFilters: ContentFilter[], requestId: string, peer: Peer): Promise<void>
-
Parameters
-
topic: string
-
-
requestId: string
-
peer: Peer
Returns Promise<void>
Implements client side of the Waku v2 Filter protocol.
Note this currently only works in NodeJS when the Waku node is listening on a port, see: