Class LightPushCore

Implements the Waku v2 Light Push protocol.

Hierarchy

  • BaseProtocol
    • LightPushCore

Implements

Constructors

constructor

Properties

addLibp2pEventListener multicodec preparePushMessage pubsubTopics removeLibp2pEventListener streamManager

Accessors

peerStore

Methods

allPeers connectedPeers getPeers getStream send

Constructors

constructor

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

multicodec

multicodec: string

Private preparePushMessage

preparePushMessage: 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>

send

  • send(encoder, message, peer): Promise<CoreSendResult>

  • Parameters

    Returns Promise<CoreSendResult>

Settings

Member Visibility

Theme

On This Page

constructoraddLibp2pEventListenermulticodecpreparePushMessagepubsubTopicsremoveLibp2pEventListenerstreamManagerpeerStoreallPeersconnectedPeersgetPeersgetStreamsend

Generated using TypeDoc