Class StreamManager

Private Readonly libp2p

Private Readonly log

Private multicodec

Private ongoingCreation

Private streamPool

Private createStream

• createStream(peerId, retries?): Promise<Stream>

• Parameters

  • peerId: PeerId
  • retries: number = 0

  Returns Promise<Stream>

Private createStreamWithLock

• createStreamWithLock(peer): Promise<void>

• Parameters

  • peer: Peer

  Returns Promise<void>

Private getOpenStreamForCodec

• getOpenStreamForCodec(peerId): undefined | Stream

• Parameters

  • peerId: PeerId

  Returns undefined | Stream

Private handlePeerUpdateStreamPool

• handlePeerUpdateStreamPool(evt): void

• Parameters

  • evt: CustomEvent<PeerUpdate>

  Returns void

Private isStreamLocked

• isStreamLocked(stream): boolean

• Parameters

  • stream: Stream

  Returns boolean

Private lockStream

• lockStream(peerId, stream): void

• Parameters

  • peerId: string
  • stream: Stream

  Returns void

Private scheduleNewStream

• scheduleNewStream(peer): void

• Parameters

  • peer: Peer

  Returns void