diff --git a/packages/stream-multiplexer-mplex/src/index.ts b/packages/stream-multiplexer-mplex/src/index.ts index 2766d94929..88b03db1e9 100644 --- a/packages/stream-multiplexer-mplex/src/index.ts +++ b/packages/stream-multiplexer-mplex/src/index.ts @@ -31,6 +31,7 @@ * ``` */ +import { serviceCapabilities } from '@libp2p/interface' import { MplexStreamMuxer, type MplexComponents } from './mplex.js' import type { StreamMuxer, StreamMuxerFactory, StreamMuxerInit } from '@libp2p/interface' @@ -91,6 +92,12 @@ class Mplex implements StreamMuxerFactory { this._init = init } + readonly [Symbol.toStringTag] = '@libp2p/mplex' + + readonly [serviceCapabilities]: string[] = [ + '@libp2p/stream-multiplexing' + ] + createStreamMuxer (init: StreamMuxerInit = {}): StreamMuxer { return new MplexStreamMuxer(this.components, { ...init, diff --git a/packages/stream-multiplexer-mplex/src/mplex.ts b/packages/stream-multiplexer-mplex/src/mplex.ts index 20b9799bcb..23746b9660 100644 --- a/packages/stream-multiplexer-mplex/src/mplex.ts +++ b/packages/stream-multiplexer-mplex/src/mplex.ts @@ -1,4 +1,4 @@ -import { CodeError, serviceCapabilities } from '@libp2p/interface' +import { CodeError } from '@libp2p/interface' import { closeSource } from '@libp2p/utils/close-source' import { RateLimiter } from '@libp2p/utils/rate-limiter' import { pipe } from 'it-pipe' @@ -120,12 +120,6 @@ export class MplexStreamMuxer implements StreamMuxer { }) } - readonly [Symbol.toStringTag] = '@libp2p/mplex' - - readonly [serviceCapabilities]: string[] = [ - '@libp2p/stream-multiplexing' - ] - /** * Returns a Map of streams and their ids */