Interface StreamMuxer

A libp2p stream muxer

interface StreamMuxer {
    protocol: string;
    sink: Sink<AsyncGenerator<Uint8Array | Uint8ArrayList, any, unknown>, unknown>;
    source: AsyncGenerator<Uint8Array | Uint8ArrayList, any, unknown>;
    streams: Stream[];
    abort(err): void;
    close(options?): Promise<void>;
    newStream(name?): Stream | Promise<Stream>;
}

Hierarchy

Duplex<AsyncGenerator<Uint8Array | Uint8ArrayList>>
- StreamMuxer

Index

Properties

protocol sink source streams

Methods

abort close newStream

Properties

protocol

protocol: string

The protocol used to select this muxer during connection opening

sink

sink: Sink<AsyncGenerator<Uint8Array | Uint8ArrayList, any, unknown>, unknown>

source

source: AsyncGenerator<Uint8Array | Uint8ArrayList, any, unknown>

`Readonly` streams

streams: Stream[]

A list of streams that are currently open. Closed streams will not be returned.

Methods

abort

abort(err): void
Close or abort all tracked streams and stop the muxer
Parameters
- err: Error
Returns void
- Defined in packages/interface/src/stream-muxer/index.ts:45

close

close(options?): Promise<void>
Close or abort all tracked streams and stop the muxer
Parameters
- Optional options: AbortOptions
Returns Promise<void>
- Defined in packages/interface/src/stream-muxer/index.ts:40

newStream

newStream(name?): Stream | Promise<Stream>
Initiate a new stream with the given name. If no name is provided, the id of the stream will be used.
Parameters
- Optional name: string
Returns Stream | Promise<Stream>
- Defined in packages/interface/src/stream-muxer/index.ts:35